CompiledStreamGraph class
Constructors
-
CompiledStreamGraph(DirectedGraph<
GraphNode> graph, Map<SourceNode, Stream> binding, {StreamTransformer<T, T> transformStream<T>(StreamNode< void doOnData(dynamic o, StreamNode)?})T> node)?,
Properties
- doOnData → (void Function(dynamic o, StreamNode)?)
-
final
-
graph
→ DirectedGraph<
GraphNode> -
final
- hashCode → int
-
The hash code for this object.
no setterinherited
-
nodesByName
↔ Map<
String, GraphNode> -
latefinal
-
outputs
→ Map<
ConversionNode, Object> -
final
- runtimeType → Type
-
A representation of the runtime type of the object.
no setterinherited
-
startStreams
↔ Map<
StreamNode, MapEntry< StreamController, StreamSubscription> > -
latefinal
-
streams
→ Map<
StreamNode, Stream> -
final
-
transformStream
→ (StreamTransformer<
T, T> Function<T>(StreamNode< T> node)?) -
final
Methods
-
close(
) → void -
forEachStartStreamController(
void f(StreamController)) → dynamic -
forEachStartStreamSubscription(
void f(StreamSubscription)) → dynamic -
forNode<
S> (StreamNode< S> node) → Stream<S> ? -
forNodeName<
S> (String name) → Stream< S> ? -
noSuchMethod(
Invocation invocation) → dynamic -
Invoked when a nonexistent method or property is accessed.
inherited
-
outputFor<
T> (ConversionNode< dynamic, T> node) → T? -
outputForName<
T> (String name) → T? -
pause(
) → void -
resume(
) → void -
toString(
) → String -
A string representation of this object.
inherited
Operators
-
operator ==(
Object other) → bool -
The equality operator.
inherited
-
operator [](
String nodeName) → Stream?