| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/channels/ |
| D | LinkedListChannelTest.kt | 21 assertEquals(3, c.receiveOrNull()) in <lambda>()
22 assertNull(c.receiveOrNull()) in <lambda>()
34 assertFailsWith<CancellationException> { q.receiveOrNull() } in testConsumeAll()
41 channel.receiveOrNull()
|
| D | ArrayBroadcastChannelTest.kt | 49 assertNull(first.receiveOrNull()) // suspends in <lambda>()
65 assertNull(second.receiveOrNull()) // suspends in <lambda>()
119 assertEquals(x, sub.receiveOrNull()) in <lambda>()
121 assertNull(sub.receiveOrNull()) in <lambda>()
156 check(sub.receiveOrNull() == null) in <lambda>()
199 subscription.receiveOrNull()
211 check(sub.receiveOrNull() == null) in <lambda>()
|
| D | ConflatedChannelTest.kt | 30 assertEquals(2, q.receiveOrNull()) in <lambda>()
44 assertNull(q.receiveOrNull()) in testConflatedClose()
85 assertFailsWith<CancellationException> { q.receiveOrNull() } in testConsumeAll()
93 channel.receiveOrNull()
|
| D | RendezvousChannelTest.kt | 45 assertEquals(42, q.receiveOrNull()) in <lambda>()
47 assertNull(q.receiveOrNull()) in <lambda>()
236 assertEquals(42, q.receiveOrNull()) in <lambda>()
238 assertNull(q.receiveOrNull()) in <lambda>()
269 assertFailsWith<CancellationException> { q.receiveOrNull() } in testConsumeAll()
277 channel.receiveOrNull()
|
| D | ArrayChannelTest.kt | 48 assertEquals(42, q.receiveOrNull()) in <lambda>()
51 assertNull(q.receiveOrNull()) in <lambda>()
137 assertFailsWith<CancellationException> { q.receiveOrNull() } in testConsumeAll()
145 channel.receiveOrNull()
163 channel.receiveOrNull() in <lambda>()
|
| D | ProduceTest.kt | 27 check(c.receiveOrNull() == null) in <lambda>()
52 assertFailsWith<CancellationException> { c.receiveOrNull() } in <lambda>()
79 assertNull(c.receiveOrNull()) in <lambda>()
|
| D | TestChannelKind.kt | 45 override suspend fun receiveOrNull(): E? = sub.receiveOrNull() in toString() method
|
| D | BasicOperationsTest.kt | 103 assertNull(channel.receiveOrNull()) in <lambda>()
122 channel.receiveOrNull() in <lambda>()
|
| D | ConflatedBroadcastChannelTest.kt | 71 assertNull(sub.receiveOrNull()) // suspends until closed in <lambda>()
|
| D | ChannelUndeliveredElementFailureTest.kt | 76 channel.receiveOrNull() in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/channels/ |
| D | ActorTest.kt | 72 val element = channel.receiveOrNull() in <lambda>()
75 val next = channel.receiveOrNull() in <lambda>()
91 val element = channel.receiveOrNull() in <lambda>()
95 channel.receiveOrNull() in <lambda>()
114 channel.receiveOrNull() in <lambda>()
|
| D | ChannelCancelUndeliveredElementStressTest.kt | 92 1 -> channel.receiveOrNull() ?: error("Cannot be closed yet") in receiveOne()
|
| D | ConflatedChannelCloseStressTest.kt | 67 curChannel.get().receiveOrNull() in <lambda>()
|
| D | BroadcastChannelMultiReceiveStressTest.kt | 129 val stop = doReceived(receiverIndex, channel.receiveOrNull() ?: break) in <lambda>()
|
| D | ChannelSendReceiveStressTest.kt | 157 doReceived(receiverIndex, channel.receiveOrNull() ?: break) in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| D | ObservableSubscriptionSelectTest.kt | 37 val r = channelB.receiveOrNull() in <lambda>()
41 val r = channelA.receiveOrNull() in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| D | ObservableSubscriptionSelectTest.kt | 37 val r = channelB.receiveOrNull() in <lambda>()
41 val r = channelA.receiveOrNull() in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | PublisherSubscriptionSelectTest.kt | 46 val r = channelB.receiveOrNull() in <lambda>()
50 val r = channelA.receiveOrNull() in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/internal/ |
| D | Combine.kt | 57 … var element = resultChannel.receiveOrNull() ?: break // Channel is closed, nothing to do here in <lambda>()
132 … val otherValue = second.receiveOrNull() ?: throw AbortFlowException(this@unsafeFlow) in zipImpl()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/guide/ |
| D | example-select-05.kt | 21 input.receiveOrNull() // and use the next deferred from the input channel in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/ |
| D | README.md | 59 …[kotlinx.coroutines.channels.ReceiveChannel] | [receiveOrNull][kotlinx.coroutines.channels.receive…
134 [kotlinx.coroutines.channels.receiveOrNull]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-co…
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/exceptions/ |
| D | StackTraceRecoveryChannelsTest.kt | 70 …ate suspend fun channelReceiveOrNull(channel: Channel<Int>) = channelOp { channel.receiveOrNull() } in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/ |
| D | README.md | 62 …[kotlinx.coroutines.channels.ReceiveChannel] | [receiveOrNull][kotlinx.coroutines.channels.receive…
147 [kotlinx.coroutines.channels.receiveOrNull]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-co…
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
| D | Channel.kt | 225 public suspend fun receiveOrNull(): E? in send() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/ |
| D | ReactiveFlow.kt | 127 suspend fun takeNextOrNull(): T? = channel.receiveOrNull() in takeNextOrNull()
|