if (!line) {
                break
            }
            print "[$line]"
        }
    }
}
'''
        executer.withStdinPipe(new PipedOutputStream() {
            @Override
            void connect(PipedInputStream snk) throws IOException {
                super.connect(snk)
                write(TextUtil.toPlatformLineSeparators("abc\n123").bytes)

                    }
                    ${outputStream}.println("Hello, " + name);
                }
            }
        """
    }

    def withStdInContents(String message) {
        executer.withStdinPipe(new PipedOutputStream() {
            @Override
            synchronized void connect(PipedInputStream snk) throws IOException {
                super.connect(snk)
                write(message.bytes)

        then:
        output.contains("response: false")
    }

    private void runInteractive(String task, String answer) {
        executer.withForceInteractive(true)
        executer.withStdinPipe()
        executer.withTasks(task, "--configuration-cache")
        def handle = executer.start()
        ConcurrentTestUtil.poll(60) {
            assert handle.standardOutput.contains("there? [yes, no]")
        }

    }

    public String getExecutable() {
        return executable;
    }

    @Override
    public GradleExecuter withStdinPipe() {
        return withStdinPipe(new PipedOutputStream());
    }

    @Override
    public GradleExecuter withStdinPipe(PipedOutputStream stdInPipe) {
        this.stdinPipe = stdInPipe;
        return this;
    }

    public InputStream connectStdIn() {

    }

    private GradleHandle startInteractiveExecutorWithTasks(String... names) {
        executer.withForceInteractive(true)
        executer.withStdinPipe()
        executer.withTasks(names)
        executer.start()
    }

    private static ExecutionResult closeInteractiveExecutor(GradleHandle handle) {
        handle.stdinPipe.close()