watcher library Null safety

Classes

Watcher<A, S>

Functions

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