import org.slf4j.LoggerFactory;

import java.util.ArrayList;
import java.util.HashSet;
import java.util.List;
import java.util.Set;

public class MessageHubBackedObjectConnection implements ObjectConnection {
    private static final Logger LOGGER = LoggerFactory.getLogger(MessageHubBackedObjectConnection.class);
    private final MessageHub hub;
    private final List<Action<Throwable>> unrecoverableErrorHandlers = new ArrayList<Action<Throwable>>();

        this.connector = connector;
        this.executorFactory = executorFactory;
    }

    @Override
    public ObjectConnection getConnection(Address address) {
        return new MessageHubBackedObjectConnection(executorFactory, connector.connect(address));
    }

            this.action = action;
        }

        @Override
        public void execute(ConnectCompletion completion) {
            action.execute(new MessageHubBackedObjectConnection(executorFactory, completion));
        }
    }

import org.gradle.test.fixtures.concurrent.ConcurrentSpec

class MessageHubBackedObjectConnectionTest extends ConcurrentSpec {
    def connectCompletion = Mock(ConnectCompletion)
    def connectionBuilder = new MessageHubBackedObjectConnection(executorFactory, connectCompletion)

    interface Worker {
        void doStuff(String value)
    }

    interface CompletableWorker extends Worker, StreamCompletion {
    }

Class <org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$1> is not annotated (directly or via its package) with @org.gradle.api.NonNullApi in (MessageHubBackedObjectConnection.java:0)
Class <org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$2> is not annotated (directly or via its package) with @org.gradle.api.NonNullApi in (MessageHubBackedObjectConnection.java:0)