Searched refs:onClosedIdempotent (Results 1 – 4 of 4) sorted by relevance
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/ | ||
| D | RxChannel.kt | 62 override fun onClosedIdempotent(closed: LockFreeLinkedListNode) { in collect() method in kotlinx.coroutines.rx3.SubscriptionChannel |
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/ | ||
| D | Channel.kt | 86 override fun onClosedIdempotent(closed: LockFreeLinkedListNode) { in consumeEach() method in kotlinx.coroutines.reactive.SubscriptionChannel |
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/ | ||
| D | RxChannel.kt | 72 override fun onClosedIdempotent(closed: LockFreeLinkedListNode) { in consumeEach() method in kotlinx.coroutines.rx2.SubscriptionChannel |
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ | ||
| D | AbstractChannel.kt | 324 onClosedIdempotent(closed) in <lambda>() |