StreamGraph class

Constructors

StreamGraph([Iterable<GraphNode> nodes = const []])

Properties

graph → DirectedGraph<GraphNode>

final

hashCode → int

The hash code for this object.

no setter, inherited

runtimeType → Type

A representation of the runtime type of the object.

no setter, inherited

Methods

addNode<T extends GraphNode>(T node) → T

compile(Map<SourceNode, Stream> binding, {StreamTransformer<T, T> transformStream<T>(StreamNode<T> node)?, void doOnData(dynamic, StreamNode)?}) → CompiledStreamGraph

finalize() → void

noSuchMethod(Invocation invocation) → dynamic

Invoked when a nonexistent method or property is accessed.

inherited

toString() → String

A string representation of this object.

inherited

Operators

operator ==(Object other) → bool

The equality operator.

inherited

Static Methods

combine2Node<R, S, T>(StreamNode<R> stream1, StreamNode<S> stream2, Stream<T> combinator(Stream<R>, Stream<S>), {String? name}) → Combine2Node<R, S, T>

combineAllFromSelectorNode<S, T>(List<StreamNode<S>> selector(StreamGraph), Stream<T> combinator(List<Stream<S>>), {String? name}) → CombineAllNode<S, T>

combineAllNode<S, T>(List<StreamNode<S>> list, Stream<T> combinator(List<Stream<S>>), {String? name}) → CombineAllNode<S, T>

copyNode<T>({required String nodeName}) → CopyNode<T>

eagerSourceNode<T>(Stream<T> stream, {String? name, bool pauseable = false}) → SourceNode<T>

shutdownNode<T>(T value, {String? name, bool pauseable = false}) → ShutdownNode<T>

sourceNode<T>({String? name, bool pauseable = false}) → SourceNode<T>