unorderedOnEachAsync
Applies the given function block to each value of the original Flow and reemits them downstream. The processing of items in the flow is concurrent and limited by concurrency level.
The result flow may emit the elements in an unordered manner, which makes this function faster than onEachAsync.
Example usage:
flowOf(1, 2, 3)
.unorderedOnEachAsync(2) { println("Processing $it") }
.collect() // Prints "Processing 1", "Processing 2", "Processing 3" in an unordered mannerReturn
A new flow with the same elements, side-effecting block applied to each item, possibly unordered.
Parameters
The maximum number of concurrent transformations.
The function to apply to each item.
Applies the given function block to each value of the original Flow and reemits them downstream. The concurrency is managed by an AsyncSemaphore created by the semaphore suspending function.
The result flow may emit the elements in an unordered manner, which makes this function faster than onEachAsync.
Example usage:
val customSemaphore: suspend CoroutineScope.() -> AsyncSemaphore = { AsyncSemaphore(this, 2) }
flowOf(1, 2, 3)
.unorderedOnEachAsync(customSemaphore) { println("Processing $it") }
.collect() // Prints "Processing 1", "Processing 2", "Processing 3" in an unordered mannerReturn
A new flow with the same elements, side-effecting block applied to each item, possibly unordered.
Parameters
The suspending function that creates an AsyncSemaphore.
The function to apply to each item.