def "can exit without cancel"() {
        when:
        monitor.monitorInput {}

        then:
        !cancellationToken.isCancellationRequested()
        executorService.shutdownNow().empty
    }


    def "closing input after monitoring doesn't trigger cancel"() {
        when:
        start {
            monitor.monitorInput {}
            writeEnd.close()
            instant.done
        }

    public PassThruCancellableOperationManager(BuildCancellationToken cancellationToken) {
        this.cancellationToken = cancellationToken;
    }

    @Override
    public void monitorInput(Action<? super BuildCancellationToken> operation) {
        operation.execute(cancellationToken);
    }

    @Override
    public void closeInput() {
    }

import org.gradle.initialization.BuildCancellationToken;

public interface CancellableOperationManager {

    /**
     * Executes the operation, while consuming System.in, watching for closure or EOT.
     */
    void monitorInput(Action<? super BuildCancellationToken> operation);

    /**
     * Perform clean-up work after build
     */
    void closeInput();

        this.executorService = executorService;
        this.input = input;
        this.cancellationToken = cancellationToken;
    }

    @Override
    public void monitorInput(final Action<? super BuildCancellationToken> operation) {
        final AtomicBoolean operationCompleted = new AtomicBoolean();
        Future<?> handle = null;
        try {

                    return lastResult;
                } else {
                    cancellableOperationManager.monitorInput(operationToken -> {
                        continuousBuildTriggerHandler.wait(
                            () -> logger.println().println("Waiting for changes to input files..." + determineExitHint(requestContext))