import java.util.HashSet;
import java.util.Set;

class ConnectionSet {
    private final Set<ConnectionState> connections = new HashSet<ConnectionState>();
    private final IncomingQueue incomingQueue;
    private final OutgoingQueue outgoingQueue;
    private boolean stopping;

    ConnectionSet(IncomingQueue incomingQueue, OutgoingQueue outgoingQueue) {
        this.incomingQueue = incomingQueue;

class ConnectionState {
    private boolean receiveFinished;
    private boolean dispatchFinished;
    private final RemoteConnection<InterHubMessage> connection;
    private final ConnectionSet owner;
    private final EndPointQueue dispatchQueue;

    ConnectionState(ConnectionSet owner, RemoteConnection<InterHubMessage> connection, EndPointQueue dispatchQueue) {
        this.owner = owner;
        this.connection = connection;

*/

type connMgr struct {
	connectionSet map[*ZtunnelConnection]struct{}
	latestConn    *ZtunnelConnection
	mu            sync.Mutex
}

func (c *connMgr) addConn(conn *ZtunnelConnection) {
	log.Debug("ztunnel connected")
	c.mu.Lock()
	defer c.mu.Unlock()
	c.connectionSet[conn] = struct{}{}
	c.latestConn = conn
	ztunnelConnected.RecordInt(int64(len(c.connectionSet)))
}

class ConnectionSetTest extends AbstractQueueTest {
    final IncomingQueue incomingQueue = new IncomingQueue(lock)
    final OutgoingQueue outgoingQueue = new OutgoingQueue(incomingQueue, lock)
    final ConnectionSet connections = new ConnectionSet(incomingQueue, outgoingQueue)

    def "discards queued outgoing messages when stop requested and no connections"() {
        def channel = new ChannelIdentifier("channel")

    private final IncomingQueue incomingQueue = new IncomingQueue(lock);
    private final OutgoingQueue outgoingQueue = new OutgoingQueue(incomingQueue, lock);
    private final ConnectionSet connections = new ConnectionSet(incomingQueue, outgoingQueue);

    /**
     * @param errorHandler Notified when some async activity fails. Must be thread-safe.
     */

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