Method #toError

node/src/transport.ts:237–240

(env: Envelope)

      async *envelopes() {
        if (started) throw new Error("an AskStream can only be consumed once");
        started = true;
        await transport.#ensureStarted();
        request.id = transport.#nextId++;
        request.kind = Envelope_Kind.REQUEST;
        const queue = new FrameQueue();
        transport.#pending.set(request.id, { kind: "stream", queue });
        try {