Home
last modified time | relevance | path

Searched defs:isClosedForReceive (Results 1 – 5 of 5) sorted by relevance

/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/linearizability/
DChannelsLCStressTest.kt107 fun isClosedForReceive() = c.isClosedForReceive in <lambda>() method
210 fun isClosedForReceive(): Boolean = isClosedForSend() && buffer.isEmpty() && senders.isEmpty() in isClosedForSend() method in SequentialIntChannelBase
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/channels/
DTestChannelKind.kt41 override val isClosedForReceive: Boolean get() = sub.isClosedForReceive in toString() constant
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/
DChannel.kt159 public val isClosedForReceive: Boolean in send() constant
DArrayChannel.kt54 override val isClosedForReceive: Boolean get() = lock.withLock { super.isClosedForReceive } in <lambda>() constant
DAbstractChannel.kt551 … public override val isClosedForReceive: Boolean get() = closedForReceive != null && isBufferEmpty constant