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

Flow parEffectMap

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. It should make use of DEFAULT_CONCURRENCY to make the amount of parallel operations configurable.

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

nomisRev avatar Dec 12 '20 10:12 nomisRev