foreachParallel
Like foreach
but allows up to parallellism
procedure calls to happen in parallel.
Signature
def foreachParallel[T](parallelism: Int)(f: T => Unit)(implicit ec: ExecutionContext): Sink[T, Future[Done]]
Description
Like foreach
but allows up to parallellism
procedure calls to happen in parallel.
cancels never
backpressures when the previous parallel procedure invocations has not yet completed