I have a List<I> and a mapping function

suspend (I)->O

. I’d like to get the

List<O>

out, running a bounded number of copies of the mapping function in parallel. I feel like this should be straightforward, eg with Flow, but I can’t quite get it to work

there is

concurrency

param in flatMapMerge

@bezrukov but flatMapMerge doesn’t preserve order, right?

yes

yeah, i do want to preserve order, so flatMapMerge is no good.

you can create dispatcher with your concurrency level and then use

map { async(yourDispatcher) { f(it) } }.awaitAll()

but it looks like overkill as well. there was a ticket for re-implementation fixedThreadPoolContext to avoid creation real dispatcher, but there is no eta.

Or use a

Semaphore

!