Interface StreamSource

node/src/streaming.ts:32–39

/** What `call_stream` registers a stream with: a transport-driven frame source. */
export interface StreamSource {
  /** Allocated correlation id (set once the stream is started). */
  readonly id: number;
  /** Async-iterate the raw envelopes for this stream (terminates on done). */
  envelopes(): AsyncGenerator<Envelope>;
  /** Write an ANSWER envelope on this stream's id. */
  answer(env: Envelope): Promise<void>;
}

/**
 * Stream-terminal `error` codes that surface as their typed exception (not the