Method envelopes

node/src/transport.ts:324–340

()

        return id;
      },
      async *envelopes() {
        if (!started) {
          started = true;
          await transport.ensureStarted();
          id = transport.#nextId++;
          req.id = id;
          req.kind = Envelope_Kind.REQUEST;
          transport.#pending.set(id, {
            kind: "stream",
            push: (e) => queue.push(e),
            end: () => queue.end(),
            fail: (e) => queue.fail(e),
          });
          transport.#write(req);
        }
        yield* queue.iterate();
      },
      async answer(env: Envelope) {
        await transport.ensureStarted();
        transport.#write(env);