import java.util.List;
import java.util.Set;
import java.util.concurrent.locks.Lock;

// TODO - use circular buffers to avoid copying
// TODO - share a single initializer with MultiChannelQueue
public class MultiEndPointQueue implements Dispatch<InterHubMessage> {
    private final Set<EndPointQueue> endpoints = new HashSet<EndPointQueue>();
    private final Deque<InterHubMessage> queue = new ArrayDeque<InterHubMessage>();

    private final Map<ChannelIdentifier, MultiEndPointQueue> channels = new HashMap<ChannelIdentifier, MultiEndPointQueue>();
    private final QueueInitializer initializer = new QueueInitializer();

    public MultiChannelQueue(Lock lock) {
        this.lock = lock;
    }

    public MultiEndPointQueue getChannel(ChannelIdentifier channel) {
        MultiEndPointQueue queue = channels.get(channel);
        if (queue == null) {

import org.gradle.internal.remote.internal.hub.queue.MultiEndPointQueue;
import org.gradle.internal.remote.internal.hub.protocol.InterHubMessage;
import org.gradle.internal.remote.internal.hub.protocol.RejectedMessage;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.locks.Lock;

class OutgoingQueue extends MultiEndPointQueue {
    private final IncomingQueue incomingQueue;

 */

package org.gradle.internal.remote.internal.hub.queue

import org.gradle.internal.remote.internal.hub.protocol.EndOfStream

class MultiEndPointQueueTest extends AbstractQueueTest {
    final MultiEndPointQueue queue = new MultiEndPointQueue(lock)

    def "forwards queued unicast messages to first waiting endpoint"() {
        given:
        def message1 = unicast()
        def message2 = unicast()

public class EndPointQueue implements Dispatch<InterHubMessage> {
    private final List<InterHubMessage> queue = new ArrayList<InterHubMessage>();
    private final MultiEndPointQueue owner;
    private final Condition condition;

    public EndPointQueue(MultiEndPointQueue owner, Condition condition) {
        this.owner = owner;
        this.condition = condition;
    }

    @Override

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