Method subscribe

packages/server-e2e/src/client.ts:411–423

Send `subscribe` and await its ack. Tracks the session for `close()`.

(sid: string)

  /** Send `subscribe` and await its ack. Tracks the session for `close()`. */
  async subscribe(sid: string): Promise<void> {
    const ws = this._requireWs();
    if (this._subscribed.has(sid)) return;
    const id = `sub-${ulid()}`;
    const ack = await ws.sendAndAwaitAck(
      { type: 'subscribe', id, payload: { session_ids: [sid] } },
      this._controlAckTimeoutMs,
    );
    if (ack.code !== 0) {
      throw new Error(`subscribe rejected (code=${ack.code}): ${ack.msg ?? 'no message'}`);
    }
    this._subscribed.add(sid);
  }

  /** Send `unsubscribe` and await its ack. */
  async unsubscribe(sid: string): Promise<void> {