Searched refs:ChannelFlowOperatorImpl (Results 1 – 3 of 3) sorted by relevance
142 … else -> ChannelFlowOperatorImpl(this, capacity = capacity, onBufferOverflow = onBufferOverflow) in buffer()245 else -> ChannelFlowOperatorImpl(this, context = context) in buffer()
16 this as? ChannelFlow ?: ChannelFlowOperatorImpl(this) in <lambda>()183 internal class ChannelFlowOperatorImpl<T>( in toString() class190 ChannelFlowOperatorImpl(flow, context, capacity, onBufferOverflow) in toString()
729 return ChannelFlowOperatorImpl(this, context, capacity, onBufferOverflow) in Array()