Method unsubscribe

packages/event-service/src/client.ts:287–306

(contexts: string[])

      clearTimeout(this.reconnectTimer);
      this.reconnectTimer = null;
    }
    this.clearHandshakeTimer();
    // If a connect handshake is still in flight, reject it so callers
    // awaiting connect() don't hang forever.
    if (this.abortHandshake) {
      this.abortHandshake(new Error('disconnected'));
    }
    if (this.ws) {
      this.ws.close();
      this.ws = null;
    }
    this.stopPing();
    this.connected = false;
  }

  /**
   * Holds the socket open for this caller. The zero-to-one transition calls
   * connect(); every subsequent call increments an internal refcount without
   * creating a second socket. Call release() when the caller no longer needs
   * the connection. Callers must pair every acquire with exactly one release.
   */
  async acquire(): Promise<void> {
    this.acquireCount++;