| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | Builders.common.kt | 53 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
|
| D | Supervisor.kt | 56 val coroutine = SupervisorCoroutine(uCont.context, uCont) in <lambda>() constant
|
| D | CoroutineScope.kt | 193 val coroutine = ScopeCoroutine(uCont.context, uCont) in coroutineScope() constant
|
| D | Timeout.kt | 99 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/ |
| D | FlowCoroutine.kt | 32 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/ |
| D | AbstractCoroutineTest.kt | 16 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/ |
| D | RxSingle.kt | 34 val coroutine = RxSingleCoroutine(newContext, subscriber) in rxSingleInternal() constant
|
| D | RxMaybe.kt | 35 val coroutine = RxMaybeCoroutine(newContext, subscriber) in rxMaybeInternal() constant
|
| D | RxCompletable.kt | 34 val coroutine = RxCompletableCoroutine(newContext, subscriber) in rxCompletableInternal() constant
|
| D | RxObservable.kt | 48 val coroutine = RxObservableCoroutine(newContext, subscriber) in rxObservableInternal() constant
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/ |
| D | RxSingle.kt | 48 val coroutine = RxSingleCoroutine(newContext, subscriber) in rxSingle() constant
|
| D | RxMaybe.kt | 49 val coroutine = RxMaybeCoroutine(newContext, subscriber) in rxMaybe() constant
|
| D | RxCompletable.kt | 48 val coroutine = RxCompletableCoroutine(newContext, subscriber) in rxCompletable() constant
|
| D | RxObservable.kt | 62 val coroutine = RxObservableCoroutine(newContext, subscriber) in rxObservable() constant
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
| D | Produce.kt | 134 val coroutine = ProducerCoroutine(newContext, channel) in produce() constant
|
| D | Broadcast.kt | 118 val coroutine = if (start.isLazy) in broadcast() constant
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/src/ |
| D | Mono.kt | 53 val coroutine = MonoCoroutine(newContext, sink) in mono() constant
|
| D | Flux.kt | 69 val coroutine = PublisherCoroutine(newContext, subscriber, REACTOR_HANDLER) in flux() constant
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/ |
| D | Builders.kt | 48 val coroutine = BlockingCoroutine<T>(newContext, eventLoop) in runBlocking() constant
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/channels/ |
| D | Actor.kt | 118 val coroutine = if (start.isLazy) in actor() constant
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | Builders.kt | 57 val coroutine = BlockingCoroutine<T>(newContext, currentThread, eventLoop) in runBlocking() constant
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/exceptions/ |
| D | SuppressionTests.kt | 19 val coroutine = object : AbstractCoroutine<String>(coroutineContext, false) { in <lambda>() constant
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-jdk8/src/future/ |
| D | Future.kt | 42 val coroutine = CompletableFutureCoroutine(newContext, future) in <lambda>() constant
|
| /external/swiftshader/src/Pipeline/ |
| D | ComputeProgram.cpp | 276 … 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
|
| /external/kotlinx.coroutines/kotlinx-coroutines-debug/test/ |
| D | CoroutinesDumpTest.kt | 108 val coroutine = DebugProbes.dumpCoroutinesInfo().first { it.job is Deferred<*> } in <lambda>() constant
|