Skip to content

Executor

class Executor

Owns per-node worker threads: source ticks, middles pop/process/push, sink drains to the session output queue. First error cancels everything.

Functions

Name Description
wait Blocks until all workers exit; returns the first error or Ok.

Function Details

wait

Status wait()

Blocks until all workers exit; returns the first error or Ok.