Invoke a given procedure asynchronously for each element received.
Invoke a given procedure asynchronously for each element received. Note that if shared state is mutated from the procedure that must be done in a thread-safe way.
The sink materializes into a
CompletionStage<Done> which completes when the stream completes, or fails if the stream fails.
foreachInvoke a given procedure for each element received.
actorRefSend the elements from the stream to an
cancels when a
backpressures when the number of
CompletionStages reaches the configured parallelism