Searched refs:cancelConsumed (Results 1 – 5 of 5) sorted by relevance
50 …return scope.broadcast(capacity = capacity, start = start, onCompletion = { cancelConsumed(it) }) { in <lambda>()
109 cancelConsumed(cause) in cause()113 internal fun ReceiveChannel<*>.cancelConsumed(cause: Throwable?) { in cancelConsumed() method136 channel.cancelConsumed(cause) in consumesAll()161 cancelConsumed(cause) in consume()
67 if (consume) channel.cancelConsumed(cause) in emitAll()
166 … val produced = produce<Int>(coroutineContext, onCompletion = { source.cancelConsumed(it) }) { in <lambda>()
638 …public static final fun cancelConsumed (Lkotlinx/coroutines/channels/ReceiveChannel;Ljava/lang/Thr…