Method waitForFirstResponse

e2e/cloud/mcp-sse-replay.test.ts:121–138

(timeoutMs: number)

  }

  waitForFirstResponse(timeoutMs: number): Promise<JsonRpcMessage> {
    const existing = this.messages.find(
      (message) => typeof message.id === "string" || typeof message.id === "number",
    );
    if (existing) return Promise.resolve(existing);
    return new Promise((resolve, reject) => {
      const timeout = setTimeout(() => {
        // oxlint-disable-next-line executor/no-promise-reject, executor/no-error-constructor -- boundary: Promise timeout adapter for e2e polling.
        reject(new Error("timed out waiting for the first JSON-RPC response"));
      }, timeoutMs);
      this.responseWaiters.push({
        resolve: (message) => {
          clearTimeout(timeout);
          resolve(message);
        },
      });
    });
  }

  abort(reason: string): void {
    this.abortController?.abort(reason);