Searched refs:OFFER_FAILED (Results 1 – 5 of 5) sorted by relevance
32 result === OFFER_FAILED -> { // try to buffer in offerInternal()54 result === OFFER_FAILED -> {} // retry in offerSelectInternal()
52 val receive = takeFirstReceiveOrPeekClosed() ?: return OFFER_FAILED in <lambda>()122 is ReceiveOrClosed<*> -> OFFER_FAILED in <lambda>()144 result === OFFER_FAILED -> { in <lambda>()198 offerResult === OFFER_FAILED -> continue@loop in <lambda>()356 !is ReceiveOrClosed<*> -> OFFER_FAILED in <lambda>()398 offerResult === OFFER_FAILED -> {} // retry in <lambda>()1018 internal val OFFER_FAILED = Symbol("OFFER_FAILED") constant
98 if (size >= capacity) return OFFER_FAILED in offerInternal()115 if (size >= capacity) return OFFER_FAILED in offerSelectInternal()
107 … failure === OFFER_FAILED -> break@loop // cannot offer -> Ok to queue to buffer in offerSelectInternal()143 BufferOverflow.SUSPEND -> OFFER_FAILED in updateBufferSize()
74 … failure === OFFER_FAILED -> break@loop // cannot offer -> Ok to queue to buffer in offerSelectInternal()