Searched refs:ReceiveOrClosed (Results 1 – 4 of 4) sorted by relevance
103 protected fun sendBuffered(element: E): ReceiveOrClosed<*>? { in <lambda>()105 if (prev is ReceiveOrClosed<*>) return@sendBuffered prev in <lambda>()122 is ReceiveOrClosed<*> -> OFFER_FAILED in <lambda>()131 protected val isFullImpl: Boolean get() = queue.nextNode !is ReceiveOrClosed<*> && isBufferFull in <lambda>()228 if (prev is ReceiveOrClosed<*>) return@enqueueSend prev in <lambda>()233 if (prev is ReceiveOrClosed<*>) return@enqueueSend prev in <lambda>()337 protected open fun takeFirstReceiveOrPeekClosed(): ReceiveOrClosed<E>? = in <lambda>()338 queue.removeFirstIfIsInstanceOfOrPeekIf<ReceiveOrClosed<E>>({ it is Closed<*> }) in <lambda>()353 ) : RemoveFirstDesc<ReceiveOrClosed<E>>(queue) { in <lambda>()356 !is ReceiveOrClosed<*> -> OFFER_FAILED in <lambda>()[all …]
34 var receive: ReceiveOrClosed<E>? = null in offerInternal()62 var receive: ReceiveOrClosed<E>? = null in offerSelectInternal()
58 var receive: ReceiveOrClosed<E>? = null in offerInternal()90 var receive: ReceiveOrClosed<E>? = null in offerSelectInternal()
245 val receive: ReceiveOrClosed<E>? in elementAt()