Function streamError

node/src/streaming.ts:52–57

* Build the error to throw for a stream-terminal ERROR frame: the typed PIN * exception for a PIN-gate verdict, else the generic AgentStreamError.

(code: string, message: string)

  async *[Symbol.asyncIterator](): AsyncIterator<AskFrame> {
    if (this.#consumed) throw new Error("an AskStream can only be consumed once");
    this.#consumed = true;
    const iterator = this.source.envelopes();
    for (;;) {
      const result = await withTimeout(iterator.next(), this.timeoutMs);
      if (result.done) return;
      const env = result.value;
      if (env.kind === Envelope_Kind.EVENT && env.payload.case === "askEvent") {
        let payload: unknown = env.payload.value.payloadJson;
        try {