concatMap

@ExperimentalCoroutinesApi()
fun <T, R> ParallelFlow<T>.concatMap(mapper: suspend (T) -> Flow<R>): ParallelFlow<R>

Maps the upstream value on each rail onto a Flow and emits their values in order on the same rail.