Home
last modified time | relevance | path

Searched refs:produceImpl (Results 1 – 5 of 5) sorted by relevance

/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/
DChannels.kt118 override fun produceImpl(scope: CoroutineScope): ReceiveChannel<T> { in receiveAsFlow() method
123 super.produceImpl(scope) // extra buffering channel in receiveAsFlow()
175 asChannelFlow().produceImpl(scope)
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/internal/
DMerge.kt51 override fun produceImpl(scope: CoroutineScope): ReceiveChannel<T> { in create() method
89 override fun produceImpl(scope: CoroutineScope): ReceiveChannel<T> { in additionalToStringProps() method
DChannelFlow.kt118 public open fun produceImpl(scope: CoroutineScope): ReceiveChannel<T> = in create() method in kotlinx.coroutines.flow.internal.ChannelFlow
123 collector.emitAll(produceImpl(this)) in create()
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/
DReactiveFlow.kt87 collector.emitAll(produceImpl(this + context)) in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/api/
Dkotlinx-coroutines-core.api1224 …public fun produceImpl (Lkotlinx/coroutines/CoroutineScope;)Lkotlinx/coroutines/channels/ReceiveCh…