Searched refs:onReceiveDequeued (Results 1 – 2 of 2) sorted by relevance
81 override fun onReceiveDequeued() { in consumeEach() method in kotlinx.coroutines.reactive.SubscriptionChannel
795 if (it != null && it !is Closed<*>) onReceiveDequeued() in takeFirstReceiveOrPeekClosed()808 protected open fun onReceiveDequeued() {} in onReceiveDequeued() method818 onReceiveDequeued() in removeReceiveOnCancel()993 channel.onReceiveDequeued() // notify cancellation of receive in resumeOnCancellationFun()