import java.util.concurrent.Callable;
import java.util.concurrent.atomic.AtomicReference;

public class WorkerLogEventListener implements OutputEventListener {
    private final AtomicReference<WorkerLoggingProtocol> workerLoggingProtocol;

    public WorkerLogEventListener() {
        this.workerLoggingProtocol = new AtomicReference<WorkerLoggingProtocol>();
    }

        final WorkerServices workerServices = new WorkerServices(basicWorkerServices, gradleUserHomeDir);
        WorkerLogEventListener workerLogEventListener = new WorkerLogEventListener();
        workerServices.add(WorkerLogEventListener.class, workerLogEventListener);

        File workingDirectory = workerServices.get(WorkerDirectoryProvider.class).getWorkingDirectory();

    private final String workerImplementationName;
    private transient CountDownLatch completed;
    private transient ResponseProtocol responder;
    private transient WorkerLogEventListener workerLogEventListener;
    private transient RequestHandler<Object, Object> implementation;
    private transient InstantiatorFactory instantiatorFactory;
    private transient Exception failure;

import org.gradle.internal.logging.events.StyledTextOutputEvent
import spock.lang.Specification

class WorkerLogEventListenerTest extends Specification {
    WorkerLogEventListener listener = new WorkerLogEventListener()

    def "listener forwards requests to the configured logging protocol object"() {
        given:
        def protocol = Mock(WorkerLoggingProtocol)
        def logEvent = Mock(LogEvent)

Class <org.gradle.process.internal.worker.child.WorkerLogEventListener> is not annotated (directly or via its package) with @org.gradle.api.NonNullApi in (WorkerLogEventListener.java:0)