Process<O, I> class

A container within which to run a processLoop

Implemented types

• ParallelizationInterface<O, I>

Constructors

Process({required Future<O> processLoop(I)})

Create a Process. Use start to activate it

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 Process right NOW irrespective or unprocessed inputs

override

kill() → void

Kill the Process 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({ReceivePort? customMainRecvPort, void onExit()?}) → Future<Stream<O>>

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

override

toString() → String

A string representation of this object.

inherited

Operators

operator ==(Object other) → bool

The equality operator.

inherited