Primary run stream for a LangGraph execution.
Implements AsyncIterable over ProtocolEvent and exposes ergonomic projections for values, messages, subgraphs, output, and interrupts. Created by createGraphRunStream.
class GraphRunStreamMerged projections from user-supplied StreamTransformer factories.
Each transformer's init() return value is spread into this object.
Namespace path identifying this stream's position in the agent tree. An empty array for the root stream.
Programmatically abort this run. Equivalent to calling
signal.abort(reason).
Messages produced by a specific graph node. Use when the run has multiple model-calling nodes and you only want messages from one.