Searched refs:ChannelFlow (Results 1 – 7 of 7) sorted by relevance
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/internal/ |
| D | Merge.kt | 20 …reate(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): ChannelFlow<R> = in <lambda>()
47 ) : ChannelFlow<T>(context, capacity, onBufferOverflow) {
48 …reate(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): ChannelFlow<T> = in create()
85 ) : ChannelFlow<T>(context, capacity, onBufferOverflow) { in additionalToStringProps()
86 …reate(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): ChannelFlow<T> = in additionalToStringProps()
|
| D | ChannelFlow.kt | 15 internal fun <T> Flow<T>.asChannelFlow(): ChannelFlow<T> = in <lambda>()
16 this as? ChannelFlow ?: ChannelFlowOperatorImpl(this) in <lambda>()
46 public abstract class ChannelFlow<T>( class
106 … create(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): ChannelFlow<T> in create()
145 ) : ChannelFlow<T>(context, capacity, onBufferOverflow) {
189 …reate(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): ChannelFlow<T> = in toString()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/ |
| D | Builders.kt | 315 ) : ChannelFlow<T>(context, capacity, onBufferOverflow) { in channelFlow()
316 …reate(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): ChannelFlow<T> = in channelFlow()
351 …reate(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): ChannelFlow<T> =
|
| D | Channels.kt | 100 ) : ChannelFlow<T>(context, capacity, onBufferOverflow) { in receiveAsFlow()
109 …reate(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): ChannelFlow<T> = in receiveAsFlow()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/ |
| D | ReactiveFlow.kt | 53 ) : ChannelFlow<T>(context, capacity, onBufferOverflow) { in <lambda>()
54 …reate(context: CoroutineContext, capacity: Int, onBufferOverflow: BufferOverflow): ChannelFlow<T> = in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/operators/ |
| D | Share.kt | 163 if (this is ChannelFlow) { in configureSharing()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/api/ |
| D | kotlinx-coroutines-core.api | 1213 public abstract class kotlinx/coroutines/flow/internal/ChannelFlow : kotlinx/coroutines/flow/intern…
1221 …ontext;ILkotlinx/coroutines/channels/BufferOverflow;)Lkotlinx/coroutines/flow/internal/ChannelFlow;
|