Method #startReader

node/src/transport.ts:179–194

* Reader: `sizeDelimitedDecodeStream` consumes the stdout (an * `AsyncIterable `) and yields fully-assembled Envelopes, * reassembling frames split across chunk boundaries for us.

(stdout: Readable)

    } else if (envelope.kind === Envelope_Kind.DONE) {
      this.#pending.delete(envelope.id);
      pending.queue.push(envelope);
      pending.queue.end();
    } else if (envelope.kind === Envelope_Kind.ERROR && envelope.payload.case === "error") {
      this.#pending.delete(envelope.id);
      pending.queue.fail(mapCoreError(envelope.payload.value));
    }
  }

  #failAll(error: Error): void {
    const pending = this.#pending;
    this.#pending = new Map();
    for (const call of pending.values()) {
      if (call.kind === "unary") {
        clearTimeout(call.timer);
        call.reject(error);
      } else {
        call.queue.fail(error);
      }
    }