Simply wrap the given job orderer.
An internal event hub used for notifying already-started async iterators.
The wrapped job orderer that actually sequences the jobs.
Implement an async iterator. It will be done when the job orderer is done, in which case the value will be undefined.
Cause all consumers of this iterable to quit with a StopJobOrdererIteration. TODO: Use an AbortController instead.
Notify all consumers that the given job has completed.
The job that completed.
Notify all consumers that the given job has failed and should be re-queued.
The job that failed to complete.
Generated using TypeDoc
Wrap a JobOrderer in an AsyncIterable. This exposes the jobs as a linear sequence that can be iterated over. The sequence can be controller and interrupted, which affects all users.