Searched refs:CancellableContinuationImpl (Results 1 – 6 of 6) sorted by relevance
63 public val reusableCancellableContinuation: CancellableContinuationImpl<*>? in <lambda>()64 get() = _reusableCancellableContinuation.value as? CancellableContinuationImpl<*> in <lambda>()66 public fun isReusable(requester: CancellableContinuationImpl<*>): Boolean { in <lambda>()81 if (value is CancellableContinuationImpl<*>) return value === requester in <lambda>()90 fun claimReusableCancellableContinuation(): CancellableContinuationImpl<T>? { in <lambda>()106 state is CancellableContinuationImpl<*> -> { in <lambda>()108 return state as CancellableContinuationImpl<T> in <lambda>()
309 … val cancellable = CancellableContinuationImpl(uCont.intercepted(), resumeMode = MODE_CANCELLABLE) in suspendCancellableCoroutine()332 …<T> getOrCreateCancellableContinuation(delegate: Continuation<T>): CancellableContinuationImpl<T> { in getOrCreateCancellableContinuation()335 return CancellableContinuationImpl(delegate, MODE_CANCELLABLE_REUSABLE) in getOrCreateCancellableContinuation()352 ?: return CancellableContinuationImpl(delegate, MODE_CANCELLABLE_REUSABLE) in getOrCreateCancellableContinuation()
26 internal open class CancellableContinuationImpl<in T>( in <lambda>() class554 fun invokeHandlers(cont: CancellableContinuationImpl<*>, cause: Throwable) { in invokeHandlers()
1161 ) : CancellableContinuationImpl<T>(delegate, MODE_CANCELLABLE) { in <lambda>()1400 private val continuation: CancellableContinuationImpl<T> in invoke()1481 @JvmField val child: CancellableContinuationImpl<*> in invoke()
230 (state as CancellableContinuationImpl<Unit>).resume(Unit) in compareAndSet()239 assert { state !is CancellableContinuationImpl<*> } in compareAndSet()245 assert { _state.value !is CancellableContinuationImpl<*> } // can be NONE or PENDING in compareAndSet()
58 public class kotlinx/coroutines/CancellableContinuationImpl : kotlin/coroutines/jvm/internal/Corout…