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

[Source]

Job sets up a new fork_join processing task and provides the user with a means to start the job and terminate it before the Generator runs out of data.

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

Constructors¶

create¶

[Source]

new tag create(
  worker_builder: WorkerBuilder[Input, Output] iso,
  generator: Generator[Input] iso,
  collector: Collector[Input, Output] iso,
  auth: SchedulerInfoAuth val,
  max_workers: USize val = 0)
: Job[Input, Output] tag^

Parameters¶

worker_builder: WorkerBuilder[Input, Output] iso
generator: Generator[Input] iso
collector: Collector[Input, Output] iso
auth: SchedulerInfoAuth val
max_workers: USize val = 0

Returns¶

Job[Input, Output] tag^

Public Behaviours¶

start¶

[Source]

Start the job.

be start()

terminate¶

[Source]

End the job before the generator has run out of data.

be terminate()