arrow-fx icon indicating copy to clipboard operation
arrow-fx copied to clipboard
verified publisher icon arrow-kt

Flow parEffectMapUnordered

Open nomisRev opened this issue 5 years ago • 0 comments

An operator for Flow<A> to execute a suspend (A) -> B function in parallel for every element while maintaining order. It should make use of DEFAULT_CONCURRENCY to make the amount of parallel operations configurable.

fun <A, B> Flow<A>.parEffectMapUnordered(f: (A) -> B): Flow<B>

nomisRev avatar Dec 12 '20 10:12 nomisRev