extensions/stream_extensions library

Functions

applyWorker<A, S>(Stream<A> actionStream, WorkerContext<S> context, Worker<A, S> worker) Future