Method constructor

e2e/cloud/mcp-sse-replay.test.ts:86–91

(
    private readonly response: Response,
    private readonly abortController?: AbortController,
  )

  readonly finished: Promise<void>;

  constructor(
    private readonly response: Response,
    private readonly abortController?: AbortController,
  ) {
    this.finished = this.consume();
  }

  waitForId(id: string, timeoutMs: number): Promise<JsonRpcMessage> {
    const existing = this.messages.find((message) => message.id === id);