@ServiceScope(Scope.Global.class)
public class CurrentBuildOperationRef {

    private static final CurrentBuildOperationRef INSTANCE = new CurrentBuildOperationRef();

    @SuppressWarnings("ThreadLocalUsage")
    private final ThreadLocal<BuildOperationRef> ref = new ThreadLocal<BuildOperationRef>();

    public static CurrentBuildOperationRef instance() {
        return INSTANCE;
    }

    @Nullable

        TimeoutHandler timeoutHandler,
        CurrentBuildOperationRef currentBuildOperationRef,
        Step<? super C, ? extends R> delegate
    ) {
        this.timeoutHandler = timeoutHandler;
        this.currentBuildOperationRef = currentBuildOperationRef;
        this.delegate = delegate;
    }

    @Override
    public R execute(UnitOfWork work, C context) {
        Optional<Duration> timeoutProperty = work.getTimeout();

    def delegate = Mock(Runnable)
    def currentBuildOperationRef = new CurrentBuildOperationRef()

    def runner() {
        CurrentBuildOperationPreservingRunnable.wrapIfNeeded(delegate, currentBuildOperationRef)
    }

    def "forward execution to delegate runnable"() {
        when:
        runner().run()

        then:

        ProblemEmitter emitter,
        ProblemStream problemStream,
        CurrentBuildOperationRef currentBuildOperationRef,
        Multimap<Throwable, Problem> problems
    ) {
        this.emitter = emitter;
        this.problemStream = problemStream;
        this.currentBuildOperationRef = currentBuildOperationRef;
        this.problems = problems;
    }

    @Override

    private final ManagedScheduledExecutor executor;
    private final CurrentBuildOperationRef currentBuildOperationRef;

    public DefaultTimeoutHandler(ManagedScheduledExecutor executor, CurrentBuildOperationRef currentBuildOperationRef) {
        this.executor = executor;
        this.currentBuildOperationRef = currentBuildOperationRef;
    }

    @Override

public class CurrentBuildOperationPreservingRunnable implements Runnable {

    public static Runnable wrapIfNeeded(Runnable delegate) {
        return wrapIfNeeded(delegate, CurrentBuildOperationRef.instance());
    }

    static Runnable wrapIfNeeded(Runnable delegate, CurrentBuildOperationRef ref) {
        if (delegate instanceof CurrentBuildOperationPreservingRunnable && ((CurrentBuildOperationPreservingRunnable) delegate).ref == ref) {

    }
    public DefaultProblems(ProblemEmitter emitter) {
        this(emitter, null, CurrentBuildOperationRef.instance());
    }

    public DefaultProblems(ProblemEmitter emitter, ProblemStream problemStream, CurrentBuildOperationRef currentBuildOperationRef) {
        this.emitter = emitter;
        this.problemStream = problemStream;
        this.currentBuildOperationRef = currentBuildOperationRef;

    private final LoggingBackedStyledTextOutput output = new LoggingBackedStyledTextOutput(listener, 'category', LogLevel.INFO, timeProvider)
    private final CurrentBuildOperationRef currentBuildOperationRef = CurrentBuildOperationRef.instance()

    def forwardsLineOfTextToListener() {
        when:
        output.println('message')

        then:

        private final CurrentBuildOperationRef currentBuildOperationRef;
        private final BuildOperationExecutionListener delegate;
        private BuildOperationState originalCurrentBuildOperation;

        private BuildOperationTrackingListener(CurrentBuildOperationRef currentBuildOperationRef, BuildOperationExecutionListener delegate) {
            this.currentBuildOperationRef = currentBuildOperationRef;

    }

    @Provides
    @Override
    protected BuildOperationProgressEventEmitter createBuildOperationProgressEventEmitter(
        Clock clock,
        CurrentBuildOperationRef currentBuildOperationRef,
        BuildOperationListenerManager listenerManager
    ) {
        return new NoOpBuildOperationProgressEventEmitter();
    }