| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | Timeout.kt | 52 var coroutine: TimeoutCoroutine<T?, T?>? = null in withTimeoutOrNull() variable
56 coroutine = timeoutCoroutine in withTimeoutOrNull()
61 if (e.coroutine === coroutine) { in withTimeoutOrNull()
69 coroutine: TimeoutCoroutine<U, T>, in setupTimeout()
73 val cont = coroutine.uCont in setupTimeout()
75 coroutine.disposeOnCompletion(context.delay.invokeOnTimeout(coroutine.time, coroutine)) in setupTimeout()
78 return coroutine.startUndispatchedOrReturnIgnoreTimeout(coroutine, block) in setupTimeout()
112 @JvmField internal val coroutine: Job? in nameString() constant
125 coroutine: Job
126 …utCancellationException = TimeoutCancellationException("Timed out waiting for $time ms", coroutine)
|
| D | Builders.common.kt | 51 val coroutine = if (start.isLazy) in <lambda>() constant
54 coroutine.start(start, coroutine, block) in <lambda>()
55 return coroutine in <lambda>()
86 val coroutine = if (start.isLazy) in async() constant
89 coroutine.start(start, coroutine, block) in async()
90 return coroutine in async()
147 val coroutine = ScopeCoroutine(newContext, uCont) // MODE_DIRECT in withContext() constant
148 return@sc coroutine.startUndispatchedOrReturn(coroutine, block) in withContext()
153 val coroutine = UndispatchedCoroutine(newContext, uCont) // MODE_UNDISPATCHED in withContext() constant
156 return@sc coroutine.startUndispatchedOrReturn(coroutine, block) in withContext()
[all …]
|
| D | Supervisor.kt | 52 val coroutine = SupervisorCoroutine(uCont.context, uCont) in <lambda>() constant
53 coroutine.startUndispatchedOrReturn(coroutine, block) in <lambda>()
|
| D | CoroutineScope.kt | 179 val coroutine = ScopeCoroutine(uCont.context, uCont) in coroutineScope() constant
180 coroutine.startUndispatchedOrReturn(coroutine, block) in coroutineScope()
|
| /external/swiftshader/third_party/llvm-7.0/llvm/docs/ |
| D | Coroutines.rst | 19 When a suspend point is reached, the execution of a coroutine is suspended and
20 control is returned back to its caller. A suspended coroutine can be resumed
24 coroutine itself) that returns a handle to a suspended coroutine
25 (**coroutine handle**) that is used by `main` to resume the coroutine twice and
41 In addition to the function stack frame which exists when a coroutine is
43 keep the coroutine state when a coroutine is suspended. This region of storage
44 is called **coroutine frame**. It is created when a coroutine is called and
45 destroyed when a coroutine runs to completion or destroyed by a call to
48 An LLVM coroutine is represented as an LLVM function that has calls to
49 `coroutine intrinsics`_ defining the structure of the coroutine.
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/ |
| D | AbstractCoroutineTest.kt | 16 val coroutine = object : AbstractCoroutine<String>(coroutineContext, false) { in <lambda>() constant
36 coroutine.invokeOnCompletion(onCancelling = true) { in <lambda>()
41 coroutine.invokeOnCompletion { in <lambda>()
46 coroutine.start() in <lambda>()
48 coroutine.resume("OK") in <lambda>()
56 … val coroutine = object : AbstractCoroutine<String>(coroutineContext + NonCancellable, false) { in <lambda>() constant
76 coroutine.invokeOnCompletion(onCancelling = true) { in <lambda>()
81 coroutine.invokeOnCompletion { in <lambda>()
87 coroutine.start() in <lambda>()
89 coroutine.cancelCoroutine(TestException1()) in <lambda>()
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
| D | Produce.kt | 97 val coroutine = ProducerCoroutine(newContext, channel) in produce() constant
98 coroutine.start(CoroutineStart.DEFAULT, coroutine, block) in produce()
99 return coroutine in produce()
123 val coroutine = ProducerCoroutine(newContext, channel) in produce() constant
124 if (onCompletion != null) coroutine.invokeOnCompletion(handler = onCompletion) in produce()
125 coroutine.start(CoroutineStart.DEFAULT, coroutine, block) in produce()
126 return coroutine in produce()
|
| D | Broadcast.kt | 80 val coroutine = if (start.isLazy) in broadcast() constant
83 if (onCompletion != null) coroutine.invokeOnCompletion(handler = onCompletion) in broadcast()
84 coroutine.start(start, coroutine, block) in broadcast()
85 return coroutine in broadcast()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/internal/ |
| D | FlowCoroutine.kt | 32 val coroutine = FlowCoroutine(uCont.context, uCont) in <lambda>() constant
33 coroutine.startUndispatchedOrReturn(coroutine, block) in <lambda>()
62 val coroutine = FlowProduceCoroutine(newContext, channel) in flowProduce() constant
63 coroutine.start(CoroutineStart.DEFAULT, coroutine, block) in flowProduce()
64 return coroutine in flowProduce()
|
| /external/python/cpython3/Doc/library/ |
| D | asyncio-task.rst | 21 :term:`Coroutines <coroutine>` declared with the async/await syntax is the
37 Note that simply calling a coroutine will not schedule it to
41 <coroutine object main at 0x1053bb7c8>
43 To actually run a coroutine, asyncio provides three main mechanisms:
48 * Awaiting on a coroutine. The following snippet of code will
132 # A coroutine object is created but not awaited,
143 In this documentation the term "coroutine" can be used for
146 * a *coroutine function*: an :keyword:`async def` function;
148 * a *coroutine object*: an object returned by calling a
149 *coroutine function*.
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/exceptions/ |
| D | SuppressionTests.kt | 19 val coroutine = object : AbstractCoroutine<String>(coroutineContext, false) { in <lambda>() constant
41 coroutine.invokeOnCompletion(onCancelling = true) { in <lambda>()
47 coroutine.invokeOnCompletion { in <lambda>()
54 coroutine.start() in <lambda>()
56 coroutine.cancelInternal(ArithmeticException()) in <lambda>()
58 coroutine.resumeWithException(IOException()) in <lambda>()
|
| /external/kotlinx.coroutines/ |
| D | coroutines-guide.md | 6 * <a name='coroutine-basics'></a>[Coroutine Basics](docs/basics.md#coroutine-basics)
7 * <a name='your-first-coroutine'></a>[Your first coroutine](docs/basics.md#your-first-coroutine)
17 …<a name='cancelling-coroutine-execution'></a>[Cancelling coroutine execution](docs/cancellation-an…
30 <!--- TOC_REF docs/coroutine-context-and-dispatchers.md -->
31 * <a name='coroutine-context-and-dispatchers'></a>[Coroutine Context and Dispatchers](docs/coroutin…
32 …* <a name='dispatchers-and-threads'></a>[Dispatchers and threads](docs/coroutine-context-and-dispa…
33 …ed-vs-confined-dispatcher'></a>[Unconfined vs confined dispatcher](docs/coroutine-context-and-disp…
34 …ing-coroutines-and-threads'></a>[Debugging coroutines and threads](docs/coroutine-context-and-disp…
35 …* <a name='jumping-between-threads'></a>[Jumping between threads](docs/coroutine-context-and-dispa…
36 …* <a name='job-in-the-context'></a>[Job in the context](docs/coroutine-context-and-dispatchers.md#…
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/channels/ |
| D | Actor.kt | 117 val coroutine = if (start.isLazy) in actor() constant
120 if (onCompletion != null) coroutine.invokeOnCompletion(handler = onCompletion) in actor()
121 coroutine.start(start, coroutine, block) in actor()
122 return coroutine in actor()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/ |
| D | Builders.kt | 48 val coroutine = BlockingCoroutine<T>(newContext, eventLoop) in runBlocking() constant
49 coroutine.start(CoroutineStart.DEFAULT, coroutine, block) in runBlocking()
50 return coroutine.joinBlocking() in runBlocking()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/ |
| D | RxCompletable.kt | 54 val coroutine = RxCompletableCoroutine(newContext, subscriber) in rxCompletable() constant
55 subscriber.setCancellable(RxCancellable(coroutine)) in rxCompletable()
56 coroutine.start(CoroutineStart.DEFAULT, coroutine, block) in rxCompletable()
|
| D | RxSingle.kt | 54 val coroutine = RxSingleCoroutine(newContext, subscriber) in rxSingle() constant
55 subscriber.setCancellable(RxCancellable(coroutine)) in rxSingle()
56 coroutine.start(CoroutineStart.DEFAULT, coroutine, block) in rxSingle()
|
| D | RxMaybe.kt | 55 val coroutine = RxMaybeCoroutine(newContext, subscriber) in rxMaybe() constant
56 subscriber.setCancellable(RxCancellable(coroutine)) in rxMaybe()
57 coroutine.start(CoroutineStart.DEFAULT, coroutine, block) in rxMaybe()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | Builders.kt | 52 val coroutine = BlockingCoroutine<T>(newContext, currentThread, eventLoop) in runBlocking() constant
53 coroutine.start(CoroutineStart.DEFAULT, coroutine, block) in runBlocking()
54 return coroutine.joinBlocking() in runBlocking()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/src/ |
| D | Flux.kt | 74 val coroutine = PublisherCoroutine(newContext, subscriber) in flux() constant
75 …subscriber.onSubscribe(coroutine) // do it first (before starting coroutine), to avoid unnecessary… in flux()
76 coroutine.start(CoroutineStart.DEFAULT, coroutine, block) in flux()
|
| D | Mono.kt | 58 val coroutine = MonoCoroutine(newContext, sink) in mono() constant
59 sink.onDispose(coroutine) in mono()
60 coroutine.start(CoroutineStart.DEFAULT, coroutine, block) in mono()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-test/ |
| D | README.md | 60 …spend functions or coroutines started with `launch` or `async` use the [runBlockingTest] coroutine
72 coroutine. Any calls to `delay` will automatically advance virtual time by the amount delayed.
76 fun testFoo() = runBlockingTest { // a coroutine with an extra test control
91 Inside of [runBlockingTest], both [launch] and [async] will start a new coroutine that may run conc…
94 To make common testing situations easier, by default the body of the coroutine is executed *eagerly…
101 // the coroutine launched by foo() is completed before foo() returns
123 If the coroutine created by `launch` or `async` calls `delay` then the [runBlockingTest] will not a…
133 … // the coroutine launched by foo has not completed here, it is suspended waiting for delay(1_000)
135 // the coroutine launched by foo has completed here
180 *Note:* Testing timeouts is simpler with a second coroutine that can be suspended (as in this examp…
[all …]
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/ |
| D | README.md | 9 …` | [CoroutineScope] | Cold mono that starts coroutine on subscribe
10 …` | [CoroutineScope] | Cold flux that starts coroutine on subscribe
27 …github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines/-coroutine-scope/index.html
28 …ithub.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines/-coroutine-dispatcher/index…
37 …s-reactor/kotlinx.coroutines.reactor/reactor.core.scheduler.-scheduler/as-coroutine-dispatcher.html
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-coroutine.hpp | 27 namespace coroutine { namespace
184 -> rxcpp::coroutine::co_observable_iterator_awaiter<rxcpp::observable<T, SourceOperator>> { in begin()
185 … return rxcpp::coroutine::co_observable_iterator_awaiter<rxcpp::observable<T, SourceOperator>>{o}; in begin()
190 -> rxcpp::coroutine::co_observable_iterator<rxcpp::observable<T, SourceOperator>> { in end()
191 return rxcpp::coroutine::co_observable_iterator<rxcpp::observable<T, SourceOperator>>{}; in end()
|
| /external/python/cpython3/Doc/c-api/ |
| D | coro.rst | 16 The C structure used for coroutine objects.
21 The type object corresponding to coroutine objects.
31 Create and return a new coroutine object based on the *frame* object,
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-jdk8/src/future/ |
| D | Future.kt | 42 val coroutine = CompletableFutureCoroutine(newContext, future) in <lambda>() constant
43 future.whenComplete(coroutine) // Cancel coroutine if future was completed externally in <lambda>()
44 coroutine.start(start, coroutine, block) in <lambda>()
|