*
 * <p>Uses a single reader thread to perform all operations.
 */
public class DaemonClientInputForwarder implements Stoppable {
    private final ForwardingUserInput forwarder;
    private final GlobalUserInputReceiver userInput;
    private final ExecutorService executor;

    public DaemonClientInputForwarder(
        InputStream inputStream,
        Dispatch<? super InputMessage> dispatch,

            } else {
                throw new IllegalArgumentException();
            }
        });
        return forwarder.forwardInput(stdinHandler -> {
            DaemonClientInputForwarder inputForwarder = new DaemonClientInputForwarder(finalStandardInput, message -> {
                if (message instanceof UserResponse) {
                    stdinHandler.onUserResponse((UserResponse) message);

        receivedCommand() instanceof CloseInput
    }

    def forwarder

    def createForwarder() {
        userInputReceiver.attachConsole(Mock(OutputEventListener))
        forwarder = new DaemonClientInputForwarder(inputStream, dispatch, userInputReceiver)
    }

    def setup() {
        createForwarder()
    }

    def closeInput() {
        source.close()
    }

    private Object monitorBuild(Build build, DaemonDiagnostics diagnostics, DaemonClientConnection connection, BuildCancellationToken cancellationToken, BuildEventConsumer buildEventConsumer) {
        DaemonClientInputForwarder inputForwarder = new DaemonClientInputForwarder(buildStandardInput, connection, userInput);
        DaemonCancelForwarder cancelForwarder = new DaemonCancelForwarder(connection, cancellationToken);
        try {