Home
last modified time | relevance | path

Searched refs:ChannelFlowMerge (Results 1 – 2 of 2) sorted by relevance

/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/internal/
DMerge.kt41 internal class ChannelFlowMerge<T>( class
49 ChannelFlowMerge(flow, concurrency, context, capacity, onBufferOverflow) in create()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/operators/
DMerge.kt141 return if (concurrency == 1) flattenConcat() else ChannelFlowMerge(this, concurrency) in merge()