stream_extensions library Null safety

Functions

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