Home
last modified time | relevance | path

Searched refs:onCloseHandler (Results 1 – 2 of 2) sorted by relevance

/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/
DConflatedBroadcastChannel.kt47 private val onCloseHandler = atomic<Any?>(null) in <lambda>() constant
178 val handler = onCloseHandler.value in <lambda>()
180 && onCloseHandler.compareAndSet(handler, HANDLER_INVOKED)) { in <lambda>()
188 if (!onCloseHandler.compareAndSet(null, handler)) { in <lambda>()
189 val value = onCloseHandler.value in <lambda>()
197 if (state is Closed && onCloseHandler.compareAndSet(handler, HANDLER_INVOKED)) { in <lambda>()
DAbstractChannel.kt41 private val onCloseHandler = atomic<Any?>(null) in <lambda>() constant in kotlinx.coroutines.channels.AbstractSendChannel
257 val handler = onCloseHandler.value in <lambda>()
259 && onCloseHandler.compareAndSet(handler, HANDLER_INVOKED)) { in <lambda>()
268 if (!onCloseHandler.compareAndSet(null, handler)) { in <lambda>()
269 val value = onCloseHandler.value in <lambda>()
277 if (closedToken != null && onCloseHandler.compareAndSet(handler, HANDLER_INVOKED)) { in <lambda>()