kotlinx-coroutines-core/kotlinx.coroutines.flow/merge

merge

fun <T> Iterable<Flow<T>>.merge(): Flow<T>(source)

fun <T> merge(vararg flows: Flow<T>): Flow<T>(source)

Merges the given flows into a single flow without preserving an order of elements. All flows are merged concurrently, without limit on the number of simultaneously collected flows.

Operator fusion

Applications of flowOn, buffer, and produceIn after this operator are fused with its concurrent merging so that only one properly configured channel is used for execution of merging logic.