Searched refs:closedForSend (Results 1 – 4 of 4) sorted by relevance
36 closedForSend?.let { return it } in offerInternal()64 closedForSend?.let { return it } in offerSelectInternal()97 if (value === EMPTY) return closedForSend ?: POLL_FAILED in pollInternal()108 if (value === EMPTY) return closedForSend ?: POLL_FAILED in pollSelectInternal()
61 closedForSend?.let { return it } in offerInternal()93 closedForSend?.let { return it } in offerSelectInternal()184 … if (size == 0) return closedForSend ?: POLL_FAILED // when nothing can be read from buffer in pollInternal()224 if (size == 0) return closedForSend ?: POLL_FAILED in pollSelectInternal()
96 closedForSend?.let { return it } in offerInternal()113 closedForSend?.let { return it } in offerSelectInternal()
83 …protected val closedForSend: Closed<*>? get() = (queue.prevNode as? Closed<*>)?.also { helpClose(i… in <lambda>() constant in kotlinx.coroutines.channels.AbstractSendChannel129 public final override val isClosedForSend: Boolean get() = closedForSend != null in <lambda>()148 … throw recoverStackTrace(helpCloseAndGetSendException(element, closedForSend ?: return false)) in <lambda>()276 val closedToken = closedForSend in <lambda>()656 val closed = closedForSend ?: error("Cannot happen") in onCancelIdempotent()