stream_graph library

Classes

Combine2Node<R, S, T>

CombineAllNode<S, T>

CompiledStreamGraph

ConversionNode<S, T>

CopyNode<T>

EagerSourceNode<T>

FilterNode<T>

GraphNode

Grouping<T, K>

GroupMapping<T, K, V>

HasInputStreamNodes

LifecycleScheduleNode<T>

Partitioning<T>

ScheduleNode<T>

ShutdownNode<T>

SingleInputNode<S, T>

SourceNode<T>

StreamGraph

StreamNode<T>

TransformNode<S, T>

Extensions

IncomingEdges on DirectedGraph<T>

LifecycleStreamNode on StreamNode<Lifecycle<T>>

Functions

byName<S>(RegExp regExp) → List<StreamNode<S>> Function(StreamGraph)

fromList<S>(List<StreamNode<S>> nodes) → List<StreamNode<S>> Function(StreamGraph)