CollectorRunner[Input: Any #send, Output: Any #send]¶

[Source]

CollectorRunner is an actor responsible for receiving messages for a Collector and coordinating job lifecycle with the other fork_join library actors.

actor tag CollectorRunner[Input: Any #send, Output: Any #send]

Constructors¶

create¶

[Source]

new tag create(
  collector: Collector[Input, Output] iso,
  coordinator: _Coordinator[Input, Output] tag)
: CollectorRunner[Input, Output] tag^

Parameters¶

collector: Collector[Input, Output] iso
coordinator: _Coordinator[Input, Output] tag

Returns¶

CollectorRunner[Input, Output] tag^

Public Functions¶

terminate¶

[Source]

Called from the user supplied collector to terminate processing before the generator is out of data.

fun ref terminate()
: None val

Returns¶

None val