concatMapEager

@FlowPreview()
fun <T, R> Flow<T>.concatMapEager(mapper: suspend (T) -> Flow<R>): Flow<R>
Content copied to clipboard

Maps the upstream values into Flows and launches them all at once, then emits items from a source before items of the next are emitted. Note that the upstream and each source is consumed in an unbounded manner and thus, depending on the speed of the current source and the collector, the operator may retain items longer and may use more memory during its execution.

Parameters

mapper

the suspendable function to turn an upstream item into a Flow