| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/channels/ |
| D | ActorLazyTest.kt | 21 assertFalse(actor.isClosedForSend) in <lambda>()
26 assertFalse(actor.isClosedForSend) in <lambda>()
34 assertTrue(actor.isClosedForSend) in <lambda>()
49 assertFalse(actor.isClosedForSend) in <lambda>()
54 assertFalse(actor.isClosedForSend) in <lambda>()
60 assertTrue(actor.isClosedForSend) in <lambda>()
|
| D | ActorTest.kt | 32 assertFalse(actor.isClosedForSend) in <lambda>()
37 assertTrue(actor.isClosedForSend) in <lambda>()
52 assertFalse(actor.isClosedForSend) in <lambda>()
57 assertFalse(actor.isClosedForSend) in <lambda>()
65 assertTrue(actor.isClosedForSend) in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/channels/ |
| D | ArrayChannelTest.kt | 43 check(q.isEmpty && !q.isClosedForSend && !q.isClosedForReceive) in <lambda>()
47 check(!q.isEmpty && q.isClosedForSend && !q.isClosedForReceive) in <lambda>()
50 check(!q.isEmpty && q.isClosedForSend && q.isClosedForReceive) in <lambda>()
59 check(!q.isEmpty && q.isClosedForSend && !q.isClosedForReceive) in <lambda>()
61 check(!q.isEmpty && q.isClosedForSend && q.isClosedForReceive) in <lambda>()
135 check(q.isClosedForSend) in testConsumeAll()
|
| D | ConflatedChannelTest.kt | 38 assertTrue(q.isClosedForSend) in testConflatedClose()
42 assertTrue(q.isClosedForSend) in testConflatedClose()
83 check(q.isClosedForSend) in testConsumeAll()
|
| D | RendezvousChannelTest.kt | 41 check(q.isEmpty && !q.isClosedForSend && !q.isClosedForReceive) in <lambda>()
54 check(!q.isEmpty && q.isClosedForSend && q.isClosedForReceive) in <lambda>()
56 check(!q.isEmpty && q.isClosedForSend && q.isClosedForReceive) in <lambda>()
267 check(q.isClosedForSend) in testConsumeAll()
|
| D | ArrayBroadcastChannelTest.kt | 39 assertFalse(broadcast.isClosedForSend) in <lambda>()
76 assertTrue(broadcast.isClosedForSend) in <lambda>()
209 assertTrue(channel.isClosedForSend) in <lambda>()
|
| D | LinkedListChannelTest.kt | 32 check(q.isClosedForSend) in testConsumeAll()
|
| D | BroadcastTest.kt | 133 assertTrue(b.isClosedForSend) // sub was also closed in <lambda>()
|
| D | BasicOperationsTest.kt | 167 assertTrue(channel.isClosedForSend) in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/linearizability/ |
| D | ChannelsLCStressTest.kt | 110 fun isClosedForSend() = c.isClosedForSend in <lambda>() method in kotlinx.coroutines.linearizability.ChannelLCStressTestBase
209 fun isClosedForSend(): Boolean = closedMessage !== null in isClosedForSend() method
210 fun isClosedForReceive(): Boolean = isClosedForSend() && buffer.isEmpty() && senders.isEmpty() in isClosedForSend()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-debug/test/ |
| D | BlockHoundTest.kt | 63 check(!q.isClosedForSend) in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/ |
| D | Channel.kt | 94 if (isClosedForSend) { in consumeEach()
|
| D | Publish.kt | 93 override val isClosedForSend: Boolean get() = isCompleted constant
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/ |
| D | RxObservable.kt | 68 override val isClosedForSend: Boolean get() = isCompleted constant
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/ |
| D | RxObservable.kt | 82 override val isClosedForSend: Boolean get() = isCompleted constant
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/ |
| D | Builders.kt | 364 if (!scope.isClosedForSend) { in collectTo()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
| D | Channel.kt | 31 public val isClosedForSend: Boolean constant
|
| D | ConflatedBroadcastChannel.kt | 96 public override val isClosedForSend: Boolean get() = _state.value is Closed in <lambda>() constant in kotlinx.coroutines.channels.ConflatedBroadcastChannel
|
| D | AbstractChannel.kt | 129 public final override val isClosedForSend: Boolean get() = closedForSend != null in <lambda>() constant
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/channels/ |
| D | ChannelBuildersFlowTest.kt | 238 assertTrue(channel.isClosedForSend) // Failure in the flow fails the channel in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/api/ |
| D | kotlinx-coroutines-reactive.api | 59 public fun isClosedForSend ()Z
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/api/ |
| D | kotlinx-coroutines-core.api | 767 public fun isClosedForSend ()Z
813 public abstract fun isClosedForSend ()Z
|
| /external/kotlinx.coroutines/ |
| D | CHANGES.md | 615 …* Make `close`, `cancel`, `isClosedForSend`, `isClosedForReceive` and `offer` linearizable with ot…
|