Skip to content
This repository has been archived by the owner on Feb 24, 2021. It is now read-only.

Flow parEffectMap #329

Open
nomisRev opened this issue Dec 12, 2020 · 0 comments
Open

Flow parEffectMap #329

nomisRev opened this issue Dec 12, 2020 · 0 comments

Comments

@nomisRev
Copy link
Member

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>
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
1 participant
@nomisRev