Searched refs:closedForReceive (Results 1 – 2 of 2) sorted by relevance
341 if (closedForReceive != null) in elementAt()343 if (isBufferEmpty && broadcastChannel.closedForReceive == null) in elementAt()356 val closedBroadcast = broadcastChannel.closedForReceive // unguarded volatile read in elementAt()361 return closedBroadcast ?: this.closedForReceive ?: POLL_FAILED in elementAt()367 val closedSub = this.closedForReceive in elementAt()
89 …protected val closedForReceive: Closed<*>? get() = (queue.nextNode as? Closed<*>)?.also { helpClos… in <lambda>() constant in kotlinx.coroutines.channels.AbstractSendChannel551 … public override val isClosedForReceive: Boolean get() = closedForReceive != null && isBufferEmpty