Method handleMessage

packages/event-service/src/client.ts:356–385

(data: string)

      if (current <= 1) {
        this.activeContexts.delete(ctx);
        released.push(ctx);
      } else {
        this.activeContexts.set(ctx, current - 1);
      }
    }
    if (released.length > 0 && this.isConnected()) {
      const message = {
        type: 'context.unsubscribe',
        contexts: released,
      } satisfies ClientMessage;
      this.send(message);
    }
  }

  onReconnect(handler: () => void): () => void {
    this.reconnectHandlers.add(handler);
    return () => {
      this.reconnectHandlers.delete(handler);
    };
  }

  /**
   * Registers a handler that fires every time the underlying WebSocket
   * transitions to OPEN — including the very first successful connect.
   *
   * If the socket is already connected at call time, the handler is called
   * synchronously before this method returns, then added to the set so it
   * also fires on future connect transitions.
   *
   * Returns an unsubscribe function. Calling it removes the handler.
   */
  onConnected(handler: () => void): () => void {
    this.connectedHandlers.add(handler);