Method RunAndProcessStderrInt

tests/testenv/cli_test_env.go:203–248

RunAndProcessStderrInt runs the given command, and streams its stderr line-by-line to stderrCallback until it returns false. The remaining lines from stderr, if any, are asynchronously sent line-by-line to stderrAsyncCallback.

(tb testing.TB, stderrCallback func(line string) bool, stderrAsyncCallback func(line string), args ...string)

// from stderr, if any, are asynchronously sent line-by-line to
// stderrAsyncCallback.
func (e *CLITest) RunAndProcessStderrInt(tb testing.TB, stderrCallback func(line string) bool, stderrAsyncCallback func(line string), args ...string) (wait func() error, interrupt func(os.Signal)) {
	tb.Helper()

	stdout, stderr, wait, interrupt := e.Runner.Start(tb, e.RunContext, e.cmdArgs(args), e.Environment)

	prefix, logOutput := e.getLogOutputPrefix()

	go func() {
		scanner := bufio.NewScanner(stdout)
		for scanner.Scan() {
			if logOutput {
				tb.Logf("[%vstdout] %v", prefix, scanner.Text())
			}
		}

		if logOutput {
			tb.Logf("[%vstdout] EOF", prefix)
		}
	}()

	scanner := bufio.NewScanner(stderr)
	for scanner.Scan() {
		if !stderrCallback(scanner.Text()) {
			break
		}
	}

	// complete stderr scanning in the background without processing lines.
	go func() {
		for scanner.Scan() {
			if stderrAsyncCallback != nil {
				stderrAsyncCallback(scanner.Text())
			}

			if logOutput {
				tb.Logf("[%vstderr] %v", prefix, scanner.Text())
			}
		}

		if logOutput {
			tb.Logf("[%vstderr] EOF", prefix)
		}
	}()

	return wait, interrupt
}

// RunAndExpectSuccessWithErrOut runs the given command, expects it to succeed and returns its stdout and stderr lines.
func (e *CLITest) RunAndExpectSuccessWithErrOut(tb testing.TB, args ...string) (stdout, stderr []string) {