| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/selects/ |
| D | SelectOld.kt | 21 uCont: Continuation<R> // unintercepted delegate continuation in <lambda>()
22 ) : SelectImplementation<R>(uCont.context) { in <lambda>()
23 private val cont = CancellableContinuationImpl(uCont.intercepted(), MODE_CANCELLABLE) in <lambda>()
61 uCont: Continuation<R> // unintercepted delegate continuation
62 ) : UnbiasedSelectImplementation<R>(uCont.context) {
63 private val cont = CancellableContinuationImpl(uCont.intercepted(), MODE_CANCELLABLE)
105 return suspendCoroutineUninterceptedOrReturn { uCont -> in selectOld() method
106 val scope = SelectBuilderImpl(uCont) in selectOld()
119 suspendCoroutineUninterceptedOrReturn { uCont -> in selectUnbiasedOld() method
120 val scope = UnbiasedSelectBuilderImpl(uCont) in selectUnbiasedOld()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/internal/ |
| D | Scopes.kt | 17 @JvmField val uCont: Continuation<T> // unintercepted continuation constant
20 final override val callerFrame: CoroutineStackFrame? get() = uCont as? CoroutineStackFrame
27 uCont.intercepted().resumeCancellableWith(recoverResult(state, uCont)) in getStackTraceElement()
32 uCont.resumeWith(recoverResult(state, uCont)) in afterResume()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | Builders.common.kt | 149 return suspendCoroutineUninterceptedOrReturn sc@ { uCont -> in withContext() method
151 val oldContext = uCont.context in withContext()
158 val coroutine = ScopeCoroutine(newContext, uCont) in withContext()
164 val coroutine = UndispatchedCoroutine(newContext, uCont) in withContext()
171 val coroutine = DispatchedCoroutine(newContext, uCont) in withContext()
213 uCont: Continuation<T>
224 uCont: Continuation<T>
225 ) : ScopeCoroutine<T>(context, uCont) {
261 uCont.intercepted().resumeCancellableWith(recoverResult(state, uCont)) in afterResume()
|
| D | Timeout.kt | 45 return suspendCoroutineUninterceptedOrReturn { uCont -> in <lambda>() method
46 setupTimeout(TimeoutCoroutine(timeMillis, uCont), block) in <lambda>()
104 return suspendCoroutineUninterceptedOrReturn { uCont -> in withTimeoutOrNull() method
105 val timeoutCoroutine = TimeoutCoroutine(timeMillis, uCont) in withTimeoutOrNull()
146 val cont = coroutine.uCont in withTimeoutOrNull()
156 uCont: Continuation<U> // unintercepted continuation
157 ) : ScopeCoroutine<T>(uCont.context, uCont), Runnable {
|
| D | Supervisor.kt | 59 return suspendCoroutineUninterceptedOrReturn { uCont -> in <lambda>() method
60 val coroutine = SupervisorCoroutine(uCont.context, uCont) in <lambda>()
71 uCont: Continuation<T> in childCancelled()
72 ) : ScopeCoroutine<T>(context, uCont) { in childCancelled()
|
| D | Yield.kt | 30 public suspend fun yield(): Unit = suspendCoroutineUninterceptedOrReturn sc@ { uCont -> in <lambda>() method
31 val context = uCont.context in <lambda>()
33 val cont = uCont.intercepted() as? DispatchedContinuation<Unit> ?: return@sc Unit in <lambda>()
|
| D | CancellableContinuation.kt | 314 suspendCoroutineUninterceptedOrReturn { uCont -> in suspendCancellableCoroutine() method
315 … val cancellable = CancellableContinuationImpl(uCont.intercepted(), resumeMode = MODE_CANCELLABLE) in suspendCancellableCoroutine()
332 ): T = suspendCoroutineUninterceptedOrReturn { uCont -> in suspendCancellableCoroutineReusable() method
333 val cancellable = getOrCreateCancellableContinuation(uCont.intercepted()) in suspendCancellableCoroutineReusable()
|
| D | CoroutineScope.kt | 262 return suspendCoroutineUninterceptedOrReturn { uCont -> in coroutineScope() method
263 val coroutine = ScopeCoroutine(uCont.context, uCont) in coroutineScope()
|
| D | CompletionState.kt | 25 internal fun <T> recoverResult(state: Any?, uCont: Continuation<T>): Result<T> = in recoverResult()
27 Result.failure(recoverStackTrace(state.cause, uCont)) in recoverResult()
|
| D | JobSupport.kt | 1228 private suspend fun awaitSuspend(): Any? = suspendCoroutineUninterceptedOrReturn { uCont -> in <lambda>() method
1234 val cont = AwaitContinuation(uCont.intercepted(), this) in <lambda>()
|
| /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>()
56 uCont: Continuation<T>
57 ) : ScopeCoroutine<T>(context, uCont) {
|
| D | ChannelFlow.kt | 225 suspendCoroutineUninterceptedOrReturn { uCont -> in emit() method
227 … block.startCoroutineUninterceptedOrReturn(value, StackFrameContinuation(uCont, newContext)) in emit()
233 private val uCont: Continuation<T>, override val context: CoroutineContext constant in StackFrameContinuation
237 get() = uCont as? CoroutineStackFrame
240 uCont.resumeWith(result) in resumeWith()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/flow/internal/ |
| D | SafeCollector.kt | 64 return suspendCoroutineUninterceptedOrReturn sc@{ uCont -> in <lambda>() method
66 emit(uCont, value) in <lambda>()
71 lastEmissionContext = DownstreamExceptionContext(e, uCont.context) in <lambda>()
77 private fun emit(uCont: Continuation<Unit>, value: T): Any? { in <lambda>()
78 val currentContext = uCont.context in <lambda>()
86 completion = uCont in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/ |
| D | CoroutineContext.kt | 53 uCont: Continuation<T> in withCoroutineContext()
54 ) : ScopeCoroutine<T>(context, uCont) { in withCoroutineContext()
55 override fun afterResume(state: Any?) = uCont.resumeWith(recoverResult(state, uCont)) in withCoroutineContext()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/src/ |
| D | CoroutineContext.kt | 57 uCont: Continuation<T> in withCoroutineContext()
58 ) : ScopeCoroutine<T>(context, uCont) { in withCoroutineContext()
59 override fun afterResume(state: Any?) = uCont.resumeWith(recoverResult(state, uCont)) in withCoroutineContext()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | CoroutineContext.kt | 167 uCont: Continuation<T>
168 …ine<T>(if (context[UndispatchedMarker] == null) context + UndispatchedMarker else context, uCont) {
236 if (uCont.context[ContinuationInterceptor] !is CoroutineDispatcher) {
268 val result = recoverResult(state, uCont) in afterResume()
269 withContinuationContext(uCont, null) { in afterResume()
270 uCont.resumeWith(result) in afterResume()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/intrinsics/ |
| D | Undispatched.kt | 119 shouldThrow(state.cause) -> throw recoverStackTrace(state.cause, uCont) in undispatchedResult()
120 result is CompletedExceptionally -> throw recoverStackTrace(result.cause, uCont) in undispatchedResult()
|