stream

fun stream(input: State, config: GraphConfig<State> = GraphConfig()): Flow<GraphEvent<State>>

Like invoke, but returns a cold Flow that emits a GraphEvent as each node starts and finishes and after every step, and ends with GraphEvent.Completed or GraphEvent.Interrupted. What a node passes to reportProgress while it runs arrives as a GraphEvent.NodeProgress, what happens inside a subgraph as a GraphEvent.SubgraphEvent, and a try of a node that failed and is followed by another as a GraphEvent.NodeRetry. Nothing runs until the flow is collected, and each collection is a new run.