Sink.foreachParallel

Like foreach but allows up to parallellism procedure calls to happen in parallel.

Sink operators

Reactive Streams semantics

cancels never

backpressures when the previous parallel procedure invocations has not yet completed