extensions/worker/watcher library

Classes

Watcher<A, S>

Functions

watcher<A, S>(Worker<A, S> worker, Stream<A> select(Stream actionStream, WorkerContext<S> context)) → Watcher<A, S>