Method collect

node/src/streaming.ts:160–171

* Drain to the final text (the `done` frame's text, else accumulated event * deltas). Throws AgentStreamError on an error outcome.

()

   * deltas). Throws {@link AgentStreamError} on an error outcome.
   */
  async collect(): Promise<string> {
    let text = "";
    for await (const f of this) {
      if (f.type === "event") {
        const p = f.payload as { delta?: string; text?: string } | undefined;
        text += p?.delta ?? p?.text ?? "";
      } else if (f.type === "done") {
        return f.text || text;
      }
    }
    return text;
  }
}