| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | Timeout.kt | 30 return suspendCoroutineUninterceptedOrReturn { uCont -> in <lambda>() method
31 setupTimeout(TimeoutCoroutine(timeMillis, uCont), block) in <lambda>()
54 return suspendCoroutineUninterceptedOrReturn { uCont -> in withTimeoutOrNull() method
55 val timeoutCoroutine = TimeoutCoroutine(timeMillis, uCont) in withTimeoutOrNull()
73 val cont = coroutine.uCont in setupTimeout()
83 @JvmField val uCont: Continuation<U> // unintercepted continuation constant in kotlinx.coroutines.TimeoutCoroutine
84 ) : AbstractCoroutine<T>(uCont.context, active = true), Runnable, Continuation<T>, CoroutineStackFr…
86 override val callerFrame: CoroutineStackFrame? get() = (uCont as? CoroutineStackFrame)
98 uCont.resumeUninterceptedWithExceptionMode(state.cause, mode) in afterCompletionInternal()
100 uCont.resumeUninterceptedMode(state as T, mode) in afterCompletionInternal()
|
| D | Supervisor.kt | 51 suspendCoroutineUninterceptedOrReturn { uCont -> in <lambda>() method
52 val coroutine = SupervisorCoroutine(uCont.context, uCont) in <lambda>()
62 uCont: Continuation<T> in childCancelled()
63 ) : ScopeCoroutine<T>(context, uCont) { in childCancelled()
|
| D | Builders.common.kt | 139 ): T = suspendCoroutineUninterceptedOrReturn sc@ { uCont -> in withContext() method
141 val oldContext = uCont.context in withContext()
147 val coroutine = ScopeCoroutine(newContext, uCont) // MODE_DIRECT in withContext()
153 val coroutine = UndispatchedCoroutine(newContext, uCont) // MODE_UNDISPATCHED in withContext()
160 val coroutine = DispatchedCoroutine(newContext, uCont) // MODE_CANCELLABLE in withContext()
205 uCont: Continuation<T>
206 ) : ScopeCoroutine<T>(context, uCont) {
217 uCont: Continuation<T>
218 ) : ScopeCoroutine<T>(context, uCont) {
|
| D | Yield.kt | 18 public suspend fun yield(): Unit = suspendCoroutineUninterceptedOrReturn sc@ { uCont -> in <lambda>() method
19 val context = uCont.context in <lambda>()
21 val cont = uCont.intercepted() as? DispatchedContinuation<Unit> ?: return@sc Unit in <lambda>()
|
| D | CancellableContinuation.kt | 197 suspendCoroutineUninterceptedOrReturn { uCont -> in suspendCancellableCoroutine() method
198 … val cancellable = CancellableContinuationImpl(uCont.intercepted(), resumeMode = MODE_CANCELLABLE) in suspendCancellableCoroutine()
220 suspendCoroutineUninterceptedOrReturn { uCont -> in suspendAtomicCancellableCoroutine() method
221 …val cancellable = CancellableContinuationImpl(uCont.intercepted(), resumeMode = MODE_ATOMIC_DEFAUL… in suspendAtomicCancellableCoroutine()
|
| D | CoroutineScope.kt | 178 suspendCoroutineUninterceptedOrReturn { uCont -> in coroutineScope() method
179 val coroutine = ScopeCoroutine(uCont.context, uCont) in coroutineScope()
|
| D | JobSupport.kt | 1162 private suspend fun awaitSuspend(): Any? = suspendCoroutineUninterceptedOrReturn { uCont -> in <lambda>() method
1168 val cont = AwaitContinuation(uCont.intercepted(), this) in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/internal/ |
| D | Scopes.kt | 16 @JvmField val uCont: Continuation<T> // unintercepted continuation constant
18 final override val callerFrame: CoroutineStackFrame? get() = uCont as CoroutineStackFrame?
29 … val exception = if (mode == MODE_IGNORE) state.cause else recoverStackTrace(state.cause, uCont) in getStackTraceElement()
30 uCont.resumeUninterceptedWithExceptionMode(exception, mode) in getStackTraceElement()
32 uCont.resumeUninterceptedMode(state as T, mode) in getStackTraceElement()
38 val cont = (this as? ScopeCoroutine<*>)?.uCont ?: return exception in tryRecover()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/internal/ |
| D | FlowCoroutine.kt | 31 suspendCoroutineUninterceptedOrReturn { uCont -> in <lambda>() method
32 val coroutine = FlowCoroutine(uCont.context, uCont) in <lambda>()
69 uCont: Continuation<T>
70 ) : ScopeCoroutine<T>(context, uCont) {
|
| D | ChannelFlow.kt | 164 suspendCoroutineUninterceptedOrReturn sc@{ uCont -> in emit() method
167 uCont.resumeWith(it) in emit()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/selects/ |
| D | SelectUnbiased.kt | 21 suspendCoroutineUninterceptedOrReturn { uCont -> in <lambda>() method
22 val scope = UnbiasedSelectBuilderImpl(uCont) in <lambda>()
33 internal class UnbiasedSelectBuilderImpl<in R>(uCont: Continuation<R>) :
35 val instance = SelectBuilderImpl(uCont)
|
| D | Select.kt | 174 suspendCoroutineUninterceptedOrReturn { uCont -> in select() method
175 val scope = SelectBuilderImpl(uCont) in select()
194 private val uCont: Continuation<R> // unintercepted delegate continuation constant in kotlinx.coroutines.selects.SelectBuilderImpl
198 get() = uCont as? CoroutineStackFrame
228 override val context: CoroutineContext get() = uCont.context in getStackTraceElement()
252 uCont.resumeWithStackTrace(result.exceptionOrNull()!!) in resumeWith()
254 uCont.resumeWith(result) in resumeWith()
262 uCont.intercepted().resumeCancellableWithException(exception) in resumeSelectCancellableWithException()
|