.collect(Collectors.toList());
    }

    private record ExecResult(
        String stdout,
        String stderr,
        int returnCode
    ) {
        @Override
        public String toString() {
            return "ExecResult{returnCode=" + returnCode + ", stdout=" + summarize(stdout) + ", stderr=" + summarize(stderr) + "}";
        }

        private static String summarize(String s) {

                                    .cwd(cwd)
                                    .userHome(userHome)
                                    .stdOut(stdout)
                                    .stdErr(stderr)
                                    .embedded(true)
                                    .build()));
                } catch (InvokerException.ExitException e) {

            @Nullable OutputStream stdOut,
            @Nullable OutputStream stdErr,
            boolean embedded)
            throws IOException {
        try (Invoker invoker = createInvoker()) {
            return invoker.invoke(createParser()
                    .parseInvocation(createParserRequestBuilder(args)
                            .stdIn(stdIn)
                            .stdOut(stdOut)
                            .stdErr(stdErr)

        }

        public Builder stdIn(InputStream stdIn) {
            this.stdIn = stdIn;
            return this;
        }

        public Builder stdOut(OutputStream stdOut) {
            this.stdOut = stdOut;
            return this;
        }

        public Builder stdErr(OutputStream stdErr) {
            this.stdErr = stdErr;
            return this;
        }

log4j.rootLogger=INFO,STDOUT
log4j.appender.STDOUT=org.apache.log4j.ConsoleAppender
log4j.appender.STDOUT.ImmediateFlush=true
log4j.appender.STDOUT.layout=org.apache.log4j.PatternLayout

    }

    private static String stdout(String... cmd) throws IOException, InterruptedException, ExecutionException {
        ExecResult r = exec(cmd);
        if (r.exitCode() != 0) {
            throw new AssertionError(String.join(" ", cmd) + " failed: " + r);
        }
        return r.stdout();
    }

    private record ExecResult(
        int exitCode,
        String stdout,
        String stderr
    ) {

            String[] args,
            ClassWorld world,
            @Nullable InputStream stdIn,
            @Nullable OutputStream stdOut,
            @Nullable OutputStream stdErr)
            throws IOException {
        return new MavenCling(world).run(args, stdIn, stdOut, stdErr, true);
    }

    public MavenCling() {
        super();
    }

    public MavenCling(ClassWorld classWorld) {

            String[] args,
            ClassWorld world,
            @Nullable InputStream stdIn,
            @Nullable OutputStream stdOut,
            @Nullable OutputStream stdErr)
            throws IOException {
        return new MavenUpCling(world).run(args, stdIn, stdOut, stdErr, true);
    }

    public MavenUpCling() {
        super();
    }

    public MavenUpCling(ClassWorld classWorld) {

import org.junit.jupiter.api.BeforeEach
import org.junit.jupiter.api.Tag
import org.junit.jupiter.api.Test
import org.junit.jupiter.api.Timeout
import org.junit.jupiter.api.extension.RegisterExtension

@Flaky // STDOUT logging enabled for test
@Timeout(30)
@Tag("Slow")
open class ConnectionListenerTest {
  @RegisterExtension
  val platform = PlatformRule()

  @RegisterExtension
  val clientTestRule = OkHttpClientTestRule()

     *
     * @return an {@link Optional} containing the output stream, or empty if not applicable
     */
    @Nonnull
    default Optional<OutputStream> stdOut() {
        return Optional.ofNullable(parserRequest().stdOut());
    }

    /**
     * Returns the error stream for the Maven execution, if running in embedded mode.
     *