Searched refs:ChannelFlowMerge (Results 1 – 2 of 2) sorted by relevance
41 internal class ChannelFlowMerge<T>( class49 ChannelFlowMerge(flow, concurrency, context, capacity, onBufferOverflow) in create()
141 return if (concurrency == 1) flattenConcat() else ChannelFlowMerge(this, concurrency) in merge()