Searched refs:onUndeliveredElement (Results 1 – 9 of 9) sorted by relevance
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/channels/ |
| D | ChannelUndeliveredElementFailureTest.kt | 25 val channel = Channel(onUndeliveredElement = onCancelFail) in isElementCancelException()
35 val channel = Channel(onUndeliveredElement = onCancelFail) in <lambda>()
48 val channel = Channel(onUndeliveredElement = onCancelFail) in <lambda>()
59 val channel = Channel(onUndeliveredElement = onCancelFail) in <lambda>()
74 val channel = Channel(onUndeliveredElement = onCancelFail) in <lambda>()
85 val channel = Channel(onUndeliveredElement = onCancelFail) in <lambda>()
100 val channel = Channel(onUndeliveredElement = onCancelFail) in <lambda>()
111 val channel = Channel(onUndeliveredElement = onCancelFail) in testReceiveOrClosedSelectCancelledFail()
126 val channel = Channel(onUndeliveredElement = onCancelFail) in <lambda>()
137 val channel = Channel(1, onUndeliveredElement = onCancelFail)
|
| D | TestChannelKind.kt | 26 fun <T> create(onUndeliveredElement: ((T) -> Unit)? = null): Channel<T> = when { in create()
27 …viaBroadcast && onUndeliveredElement != null -> error("Broadcast channels to do not support onUnde… in create()
29 else -> Channel(capacity, onUndeliveredElement = onUndeliveredElement) in create()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
| D | Channel.kt | 647 onUndeliveredElement: ((E) -> Unit)? = null in Channel()
652 … RendezvousChannel(onUndeliveredElement) // an efficient implementation of rendezvous channel in Channel()
654 …ArrayChannel(1, onBufferOverflow, onUndeliveredElement) // support buffer overflow with buffered c… in Channel()
660 ConflatedChannel(onUndeliveredElement) in Channel()
662 …UNLIMITED -> LinkedListChannel(onUndeliveredElement) // ignores onBufferOverflow: it has buffer, b… in Channel()
665 onBufferOverflow, onUndeliveredElement in Channel()
669 …ConflatedChannel(onUndeliveredElement) // conflated implementation is more efficient but appears t… in Channel()
671 ArrayChannel(capacity, onBufferOverflow, onUndeliveredElement) in Channel()
|
| D | AbstractChannel.kt | 20 @JvmField protected val onUndeliveredElement: OnUndeliveredElement<E>? in <lambda>() constant in kotlinx.coroutines.channels.AbstractSendChannel
162 onUndeliveredElement?.callUndeliveredElementCatchingException(element)?.let { in <lambda>()
173 val send = if (onUndeliveredElement == null) in <lambda>()
175 SendElementWithUndeliveredHandler(element, cont, onUndeliveredElement) in <lambda>()
211 onUndeliveredElement?.callUndeliveredElementCatchingException(element)?.let { in <lambda>()
468 … channel.onUndeliveredElement?.callUndeliveredElement(pollResult, select.completion.context) in <lambda>()
489 onUndeliveredElement: OnUndeliveredElement<E>?
490 ) : AbstractSendChannel<E>(onUndeliveredElement), Channel<E> {
571 val receive = if (onUndeliveredElement == null) in receiveSuspend()
573 …entWithUndeliveredHandler(cont as CancellableContinuation<Any?>, receiveMode, onUndeliveredElement) in receiveSuspend()
[all …]
|
| D | ArrayChannel.kt | 28 onUndeliveredElement: OnUndeliveredElement<E>?
29 ) : AbstractChannel<E>(onUndeliveredElement) {
285 val onUndeliveredElement = onUndeliveredElement in onCancelIdempotent() constant
290 if (onUndeliveredElement != null && value !== EMPTY) { in onCancelIdempotent()
292 …undeliveredElementException = onUndeliveredElement.callUndeliveredElementCatchingException(value a… in onCancelIdempotent()
|
| D | RendezvousChannel.kt | 18 …open class RendezvousChannel<E>(onUndeliveredElement: OnUndeliveredElement<E>?) : AbstractChannel<…
|
| D | ConflatedChannel.kt | 20 … open class ConflatedChannel<E>(onUndeliveredElement: OnUndeliveredElement<E>?) : AbstractChannel<…
129 onUndeliveredElement?.callUndeliveredElementCatchingException(old as E) in updateValueLocked()
|
| D | LinkedListChannel.kt | 20 …open class LinkedListChannel<E>(onUndeliveredElement: OnUndeliveredElement<E>?) : AbstractChannel<…
|
| /external/kotlinx.coroutines/ |
| D | CHANGES.md | 50 * Support leak-free closeable resources transfer via `onUndeliveredElement` in channels (#1936).
|