Method waitForSubscription

tests/ipc/streamCollector.ts:77–101

* Wait for the ORPC subscription to be fully established. * This waits for the "caught-up" event from the server, which is emitted * after the event subscription is set up and history replay is complete. * Call this after start() and before sending messages to avoid race conditions.

(timeoutMs: number = 5000)

   * Call this after start() and before sending messages to avoid race conditions.
   */
  async waitForSubscription(timeoutMs: number = 5000): Promise<void> {
    if (!this.started) {
      throw new Error("StreamCollector not started. Call start() first.");
    }
    if (this.subscriptionReady) {
      return;
    }

    return new Promise<void>((resolve, reject) => {
      const timer = setTimeout(() => {
        reject(new Error(`Subscription setup timed out after ${timeoutMs}ms`));
      }, timeoutMs);

      this.subscriptionReadyResolve = () => {
        clearTimeout(timer);
        resolve();
      };

      // If already ready (race condition), resolve immediately
      if (this.subscriptionReady) {
        clearTimeout(timer);
        resolve();
      }
    });
  }

  /**
   * Stop collecting and cleanup.