Searched refs:takeFirstReceiveOrPeekClosed (Results 1 – 4 of 4) sorted by relevance
41 … receive = takeFirstReceiveOrPeekClosed() ?: break@loop // break when no receivers queued in offerInternal()
52 val receive = takeFirstReceiveOrPeekClosed() ?: return OFFER_FAILED in <lambda>()337 protected open fun takeFirstReceiveOrPeekClosed(): ReceiveOrClosed<E>? = in <lambda>() method793 override fun takeFirstReceiveOrPeekClosed(): ReceiveOrClosed<E>? = in takeFirstReceiveOrPeekClosed() method794 super.takeFirstReceiveOrPeekClosed().also { in takeFirstReceiveOrPeekClosed()
257 … receive = takeFirstReceiveOrPeekClosed() ?: break // break when no one's receiving in elementAt()
67 … receive = takeFirstReceiveOrPeekClosed() ?: break@loop // break when no receivers queued in offerInternal()