mapAsyncUnordered
Like mapAsync
but Future
results are passed downstream as they arrive regardless of the order of the elements that triggered them.
Description
Like mapAsync
but Future
results are passed downstream as they arrive regardless of the order of the elements that triggered them.
If a Future
completes with null
, element is not passed downstream. If a Future
fails, the stream also fails (unless a different supervision strategy is applied)
emits any of the Future
s returned by the provided function complete
backpressures when the number of Future
s reaches the configured parallelism and the downstream backpressures
completes upstream completes and all Future
s has been completed and all elements has been emitted