Method consume

e2e/cloud/mcp-sse-replay.test.ts:116–137

()

  }

  private async consume(): Promise<void> {
    const reader = this.response.body?.getReader();
    if (!reader) return;
    this.reader = reader;
    const decoder = new TextDecoder();
    let buffer = "";
    try {
      for (;;) {
        const { done, value } = await reader.read();
        if (done) break;
        buffer += decoder.decode(value, { stream: true });
        buffer = this.consumeBlocks(buffer);
      }
      buffer += decoder.decode();
      this.consumeBlocks(`${buffer}\n\n`);
    } catch {
      return;
    } finally {
      if (this.reader === reader) this.reader = null;
      reader.releaseLock();
    }
  }

  private consumeBlocks(buffer: string): string {
    let next = buffer;