executor.execute(standardOutputReader);
    }

    @Override
    public void removeStartupContext() {
        standardOutputReader.clearAssociatedBuildOperation();
        if (readErrorStream) {
            standardErrorReader.clearAssociatedBuildOperation();
        }
    }

    @Override
    public void stop() {
        try {
            completed.await();
        } catch (InterruptedException e) {

        this.completed = completed;
    }

    public void associateBuildOperation(BuildOperationRef startupRef) {
        this.associatedBuildOperation = startupRef;
    }

    public void clearAssociatedBuildOperation() {
        this.associatedBuildOperation = null;
    }

    @Override
    public void run() {
        try {
            forwardContent();
        } finally {
            completed.countDown();