ProcessingLine<O, I> class
Order Processes and ProcessGroups sequentially to complete a complex, multi-step workload akin to how factory lines work.
- Implemented types
-
- ParallelizationInterface<
O, I>
- ParallelizationInterface<
Constructors
- ProcessingLine()
-
Create a
ProcessingLine
Properties
- hashCode → int
-
The hash code for this object.
no setterinherited
- iType ↔ Type
-
Input Type for this process
latefinaloverride-getter
- oType ↔ Type
-
Output Type for this process
latefinaloverride-getter
- runtimeType → Type
-
A representation of the runtime type of the object.
no setterinherited
-
stream
↔ Stream<
O> -
A Stream with processed outputs
latefinaloverride-getter
Methods
-
addStation<
o, i> (ParallelizationInterface< o, i> station) → void -
Add a new station to the
ProcessingLine -
forceKill(
) → void -
Kill the relevant Isolates IMMEDIATELY irrespective of pending inputs
override
-
kill(
) → void -
Kill the relevant Isolates after processing all current inputs
override
-
noSuchMethod(
Invocation invocation) → dynamic -
Invoked when a nonexistent method or property is accessed.
inherited
-
send(
I data) → void -
Send data for processing;
override
-
start(
) → Future< Stream< O> > -
Start the required Isolates and perform a "hand-shake"
override
-
toString(
) → String -
A string representation of this object.
inherited
Operators
-
operator ==(
Object other) → bool -
The equality operator.
inherited