Home
last modified time | relevance | path

Searched defs:coroutine (Results 1 – 25 of 39) 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
152 val coroutine = ScopeCoroutine(newContext, uCont) in withContext() constant
158 val coroutine = UndispatchedCoroutine(newContext, uCont) in withContext() constant
165 val coroutine = DispatchedCoroutine(newContext, uCont) in withContext() constant
DSupervisor.kt56 val coroutine = SupervisorCoroutine(uCont.context, uCont) in <lambda>() constant
DCoroutineScope.kt193 val coroutine = ScopeCoroutine(uCont.context, uCont) in coroutineScope() constant
DTimeout.kt99 var coroutine: TimeoutCoroutine<T?, T?>? = null in withTimeoutOrNull() variable
168 @JvmField internal val coroutine: Job? in nameString() constant
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/internal/
DFlowCoroutine.kt32 val coroutine = FlowCoroutine(uCont.context, uCont) in <lambda>() constant
61 val coroutine = FlowProduceCoroutine(newContext, channel) in flowProduce() constant
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/
DAbstractCoroutineTest.kt16 val coroutine = object : AbstractCoroutine<String>(coroutineContext, false) { in <lambda>() constant
56 … val coroutine = object : AbstractCoroutine<String>(coroutineContext + NonCancellable, 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.kt49 val coroutine = RxMaybeCoroutine(newContext, subscriber) in rxMaybe() constant
DRxSingle.kt48 val coroutine = RxSingleCoroutine(newContext, subscriber) in rxSingle() constant
DRxCompletable.kt48 val coroutine = RxCompletableCoroutine(newContext, subscriber) in rxCompletable() constant
DRxObservable.kt62 val coroutine = RxObservableCoroutine(newContext, subscriber) in rxObservable() constant
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/
DProduce.kt134 val coroutine = ProducerCoroutine(newContext, channel) in produce() constant
DBroadcast.kt118 val coroutine = if (start.isLazy) in broadcast() constant
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/src/
DMono.kt53 val coroutine = MonoCoroutine(newContext, sink) in mono() constant
DFlux.kt69 val coroutine = PublisherCoroutine(newContext, subscriber, REACTOR_HANDLER) in flux() constant
/external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/
DBuilders.kt48 val coroutine = BlockingCoroutine<T>(newContext, eventLoop) in runBlocking() constant
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/channels/
DActor.kt118 val coroutine = if (start.isLazy) in actor() 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, false) { in <lambda>() constant
/external/kotlinx.coroutines/integration/kotlinx-coroutines-jdk8/src/future/
DFuture.kt42 val coroutine = CompletableFutureCoroutine(newContext, future) in <lambda>() constant
/external/swiftshader/tests/ReactorBenchmarks/
DReactorBenchmarks.cpp56 auto coroutine = function(); in BENCHMARK_DEFINE_F() local
/external/swiftshader/src/Pipeline/
DComputeProgram.cpp276 … auto coroutine = (*this)(&data, groupX, groupY, groupZ, workgroupMemory.data(), subgroupIndex, 1); in run() local
282 …auto coroutine = (*this)(&data, groupX, groupY, groupZ, workgroupMemory.data(), 0, subgroupsPerWor… in run() local
288 auto coroutine = std::move(coroutines.front()); in run() local

12