Transform and flatten Futures concurrently, limiting concurrency to at most WorkerConfig.workerCount workers
Transform and flatten Futures concurrently, limiting concurrency to at most WorkerConfig.workerCount workers
a Future of M[B] that completes once all Futures have been transformed
Traverse Futures concurrently, limiting concurrency to at most WorkerConfig.workerCount workers
Traverse Futures concurrently, limiting concurrency to at most WorkerConfig.workerCount workers
a Future of M[B] that completes once all Futures have been transformed
Transform Futures concurrently, limiting concurrency to at most WorkerConfig.workerCount workers
Transform Futures concurrently, limiting concurrency to at most WorkerConfig.workerCount workers
a Future of M[B] that completes once all Futures have been transformed
Using the collection members xa, concurrently execute a processing function f, outputting the result of f to the function g.
Using the collection members xa, concurrently execute a processing function f, outputting the result of f to the function g. Concurrency is limited to the number of workers specified in WorkersConfig. Any exception that occurs during a worker's processing will cause a AsyncParThrowable to be immediately returned. Any other exceptions from workers that have yet to complete can be retrieved from AsyncParThrowable.
the type processed
the output type
specifies the number of workers
the collection
the processing function
the output function
a Future that completes once all workers have completed.