createGraphRunStream<
TValues = Record<string, unknown>,
TTransformers extends readonly () =
> StreamTransformer| Name | Type | Description |
|---|---|---|
source* | AsyncIterable<StreamChunk> | |
transformers | TTransformers | Default: ... |
optionsOrAbortController | AbortController | CreateGraphRunStreamOptions |
Creates a GraphRunStream with built-in transformers and kicks off the background pump that feeds raw stream chunks through the transformer pipeline.
Built-in transformers are registered in this order:
_discoveries log.lifecycle channel events.run.values / run.output.run.messages / .messagesFrom.Subgraph discovery is registered first so that downstream transformers (notably lifecycle) observe child namespaces with their stream handles already in place. User-supplied transformer factories are registered afterwards.
Raw async iterable from graph.stream(…, { subgraphs: true }).
User-supplied transformer factories.
Either a full
CreateGraphRunStreamOptions object or (for backward
compatibility) a bare AbortController.