stream<
TStreamMode extends StreamMode | StreamMode[] | undefined,
TSubgraphs | Name | Type | Description |
|---|---|---|
input* | ExtractUpdateType<I, ExtractStateType<I, I>> | CommandInstance<InferInterruptResumeType<InterruptType, false>, { [K in string | number | symbol]: U[K] }, N> | null | |
options | Partial<PregelOptions<Record<"__start__" | N, PregelNode<S, U>>, Record<string | N, BaseChannel<unknown, unknown, unknown>>, ExtractStateType<C |
Streams the execution of the graph, emitting state updates as they occur. This is the primary method for observing graph execution in real-time.
Stream modes:
The input to start graph execution with
Configuration options for streaming