ProcessGroup<O, I> class

Create a bunch of Processes that run the same processLoop.

Implemented types

• ParallelizationInterface<O, I>

Constructors

ProcessGroup({required Future<O> processLoop(I), int? processCount})

Create a ProcessGroup

Properties

hashCode → int

The hash code for this object.

no setter, inherited

iType ↔ Type

Input Type for this process

late, final, override-getter

oType ↔ Type

Output Type for this process

late, final, override-getter

runtimeType → Type

A representation of the runtime type of the object.

no setter, inherited

stream ↔ Stream<O>

Stream with processed outputs

late, final, override-getter

Methods

forceKill() → void

Kill the ProcessGroup right NOW irrespective or unprocessed inputs

override

kill() → void

Kill the ProcessGroup after all current inputs are processed

override

noSuchMethod(Invocation invocation) → dynamic

Invoked when a nonexistent method or property is accessed.

inherited

send(I data) → void

Send data to the Process

override

start() → Future<Stream<O>>

Start up the ProcessGroup. Call this before sending any data to the ProcessGroup

override

toString() → String

A string representation of this object.

inherited

Operators

operator ==(Object other) → bool

The equality operator.

inherited