Searched refs:_reusableCancellableContinuation (Results 1 – 1 of 1) sorted by relevance
61 private val _reusableCancellableContinuation = atomic<Any?>(null) in <lambda>() constant64 get() = _reusableCancellableContinuation.value as? CancellableContinuationImpl<*> in <lambda>()80 val value = _reusableCancellableContinuation.value ?: return false in <lambda>()96 _reusableCancellableContinuation.loop { state -> in <lambda>()103 _reusableCancellableContinuation.value = REUSABLE_CLAIMED in <lambda>()107 if (_reusableCancellableContinuation.compareAndSet(state, REUSABLE_CLAIMED)) { in <lambda>()131 _reusableCancellableContinuation.loop { state -> in <lambda>()135 … if (_reusableCancellableContinuation.compareAndSet(REUSABLE_CLAIMED, continuation)) return null in <lambda>()139 require(_reusableCancellableContinuation.compareAndSet(state, null)) in <lambda>()152 _reusableCancellableContinuation.loop { state -> in <lambda>()[all …]