Home
last modified time | relevance | path

Searched defs:coroutine (Results 1 – 25 of 40) sorted by relevance

12

/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/
DBuilders.common.kt53 val coroutine = if (start.isLazy) in <lambda>() constant
88 val coroutine = if (start.isLazy) in async() constant
158 val coroutine = ScopeCoroutine(newContext, uCont) in withContext() constant
164 val coroutine = UndispatchedCoroutine(newContext, uCont) in withContext() constant
171 val coroutine = DispatchedCoroutine(newContext, uCont) in withContext() constant
DSupervisor.kt60 val coroutine = SupervisorCoroutine(uCont.context, uCont) in <lambda>() constant
DCoroutineScope.kt263 val coroutine = ScopeCoroutine(uCont.context, uCont) in coroutineScope() constant
DTimeout.kt102 var coroutine: TimeoutCoroutine<T?, T?>? = null in withTimeoutOrNull() variable
171 @JvmField @Transient internal val coroutine: Job? in nameString() constant
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/
DAbstractCoroutineTest.kt16 val coroutine = object : AbstractCoroutine<String>(coroutineContext, true, false) { in <lambda>() constant
56 …val coroutine = object : AbstractCoroutine<String>(coroutineContext + NonCancellable, true, false)… in <lambda>() constant
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/
DRxMaybe.kt35 val coroutine = RxMaybeCoroutine(newContext, subscriber) in rxMaybeInternal() constant
DRxSingle.kt34 val coroutine = RxSingleCoroutine(newContext, subscriber) in rxSingleInternal() constant
DRxCompletable.kt34 val coroutine = RxCompletableCoroutine(newContext, subscriber) in rxCompletableInternal() constant
DRxObservable.kt48 val coroutine = RxObservableCoroutine(newContext, subscriber) in rxObservableInternal() constant
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/
DRxMaybe.kt35 val coroutine = RxMaybeCoroutine(newContext, subscriber) in rxMaybeInternal() constant
DRxSingle.kt34 val coroutine = RxSingleCoroutine(newContext, subscriber) in rxSingleInternal() constant
DRxCompletable.kt34 val coroutine = RxCompletableCoroutine(newContext, subscriber) in rxCompletableInternal() constant
DRxObservable.kt48 val coroutine = RxObservableCoroutine(newContext, subscriber) in rxObservableInternal() constant
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/internal/
DFlowCoroutine.kt32 val coroutine = FlowCoroutine(uCont.context, uCont) in <lambda>() constant
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/
DProduce.kt130 val coroutine = ProducerCoroutine(newContext, channel) in produce() constant
DBroadcast.kt126 val coroutine = if (start.isLazy) in broadcast() constant
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/src/
DFlux.kt53 val coroutine = PublisherCoroutine(newContext, subscriber, REACTOR_HANDLER) in reactorPublish() constant
DMono.kt90 val coroutine = MonoCoroutine(newContext, sink) in awaitSingle() constant
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/
DBuilders.kt57 val coroutine = BlockingCoroutine<T>(newContext, currentThread, eventLoop) in runBlocking() constant
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/exceptions/
DSuppressionTests.kt19 val coroutine = object : AbstractCoroutine<String>(coroutineContext, true, false) { in <lambda>() constant
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/channels/
DActor.kt118 val coroutine = if (start.isLazy) in actor() constant
/external/kotlinx.coroutines/docs/topics/
Ddebug-flow-with-idea.md105 ### Optimized-out variables
/external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/
DBuilders.kt54 val coroutine = BlockingCoroutine<T>(newContext, eventLoop) in runBlocking() constant
/external/swiftshader/src/Pipeline/
DComputeProgram.cpp256 …auto coroutine = (*this)(device, &data, groupX, groupY, groupZ, workgroupMemory.data(), subgroupIn… in run() local
262 …auto coroutine = (*this)(device, &data, groupX, groupY, groupZ, workgroupMemory.data(), 0, subgrou… in run() local
268 auto coroutine = std::move(coroutines.front()); in run() local
/external/kotlinx.coroutines/kotlinx-coroutines-core/jdk8/src/future/
DFuture.kt42 val coroutine = CompletableFutureCoroutine(newContext, future) in <lambda>() constant

12