Searched refs:_reusableCancellableContinuation (Results 1 – 1 of 1) sorted by relevance
52 private val _reusableCancellableContinuation = atomic<Any?>(null) in <lambda>() constant55 get() = _reusableCancellableContinuation.value as? CancellableContinuationImpl<*> in <lambda>()64 return _reusableCancellableContinuation.value != null in <lambda>()72 _reusableCancellableContinuation.loop { in <lambda>()98 _reusableCancellableContinuation.loop { state -> in <lambda>()105 _reusableCancellableContinuation.value = REUSABLE_CLAIMED in <lambda>()110 if (_reusableCancellableContinuation.compareAndSet(state, REUSABLE_CLAIMED)) { in <lambda>()142 _reusableCancellableContinuation.loop { state -> in <lambda>()146 … if (_reusableCancellableContinuation.compareAndSet(REUSABLE_CLAIMED, continuation)) return null in <lambda>()149 require(_reusableCancellableContinuation.compareAndSet(state, null)) in <lambda>()[all …]