Home
last modified time | relevance | path

Searched refs:onReceiveOrNull (Results 1 – 18 of 18) sorted by relevance

/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/guide/
Dexample-select-02.kt14 a.onReceiveOrNull { value -> in <lambda>()
20 b.onReceiveOrNull { value -> in <lambda>()
Dexample-select-05.kt16 input.onReceiveOrNull { update -> in <lambda>()
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/
DObservableSubscriptionSelectTest.kt25 channelA.onReceiveOrNull { in <lambda>()
29 channelB.onReceiveOrNull { in <lambda>()
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/
DObservableSubscriptionSelectTest.kt25 channelA.onReceiveOrNull { in <lambda>()
29 channelB.onReceiveOrNull { in <lambda>()
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/
DPublisherSubscriptionSelectTest.kt34 channelA.onReceiveOrNull { in <lambda>()
38 channelB.onReceiveOrNull { in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/channels/
DTestChannelKind.kt58 override val onReceiveOrNull: SelectClause1<E?> in toString() constant
59 get() = sub.onReceiveOrNull in toString()
DChannelUndeliveredElementFailureTest.kt88 channel.onReceiveOrNull { in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/operators/
DDelay.kt241 values.onReceiveOrNull { value -> in debounceInternal()
289 values.onReceiveOrNull { in sample()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/selects/
DSelectLoopTest.kt30 channel.onReceiveOrNull { in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/
DREADME.md59 …kotlinx.coroutines.channels.receiveOrNull] | [onReceiveOrNull][kotlinx.coroutines.channels.onRecei…
135 [kotlinx.coroutines.channels.onReceiveOrNull]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-…
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/channels/
DBroadcastChannelMultiReceiveStressTest.kt153 val event = select<Long?> { channel.onReceiveOrNull { it } } ?: break in <lambda>()
DChannelSendReceiveStressTest.kt178 val event = select<Int?> { channel.onReceiveOrNull { it } } ?: break in <lambda>()
DChannelUndeliveredElementStressTest.kt192 … 4 -> select { channel.onReceiveOrNull { it ?: error("Should not be closed") } } in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/
DREADME.md62 …kotlinx.coroutines.channels.receiveOrNull] | [onReceiveOrNull][kotlinx.coroutines.channels.onRecei…
148 [kotlinx.coroutines.channels.onReceiveOrNull]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-…
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/
DChannel.kt243 public val onReceiveOrNull: SelectClause1<E?> in send() constant
DChannels.common.kt72 public fun <E : Any> ReceiveChannel<E>.onReceiveOrNull(): SelectClause1<E?> { in onReceiveOrNull() method
74 return (this as ReceiveChannel<E?>).onReceiveOrNull in onReceiveOrNull()
DAbstractChannel.kt716 final override val onReceiveOrNull: SelectClause1<E?> constant
/external/kotlinx.coroutines/kotlinx-coroutines-core/api/
Dkotlinx-coroutines-core.api717 …public static final fun onReceiveOrNull (Lkotlinx/coroutines/channels/ReceiveChannel;)Lkotlinx/cor…