Method #failAll

node/src/transport.ts:242–249

(err: Error)

        request.kind = Envelope_Kind.REQUEST;
        const queue = new FrameQueue();
        transport.#pending.set(request.id, { kind: "stream", queue });
        try {
          transport.#write(request);
          yield* queue.iterate();
        } finally {
          transport.#pending.delete(request.id);
        }
      },
    };
    return new AskStream(source, this.config.timeoutMs);
  }