| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/ |
| D | JobTest.kt | 24 job.invokeOnCompletion { fireCount++ } in <lambda>()
42 for (i in 0 until n) job.invokeOnCompletion { fireCount[i]++ } in <lambda>()
62 registration = job.invokeOnCompletion { in <lambda>()
84 … val registrations = Array<DisposableHandle>(n) { i -> job.invokeOnCompletion { fireCount[i]++ } } in <lambda>()
99 for (i in 0 until n) job.invokeOnCompletion { in <lambda>()
125 val handler = job.invokeOnCompletion { fireCount++ } in <lambda>()
136 val handlers = Array(handlerCount) { job.invokeOnCompletion { fireCount++ } } in <lambda>()
168 job.invokeOnCompletion(onCancelling = true) { in <lambda>()
214 coroutineContext[Job]!!.invokeOnCompletion { } in <lambda>()
|
| D | AbstractCoroutineTest.kt | 36 coroutine.invokeOnCompletion(onCancelling = true) { in <lambda>()
41 coroutine.invokeOnCompletion { in <lambda>()
76 coroutine.invokeOnCompletion(onCancelling = true) { in <lambda>()
81 coroutine.invokeOnCompletion { in <lambda>()
|
| D | AsyncTest.kt | 244 coroutineContext[Job]!!.invokeOnCompletion { } in <lambda>()
258 coroutineContext[Job]!!.invokeOnCompletion { } in <lambda>()
|
| D | CompletableDeferredTest.kt | 32 assertEquals(true, c.complete(c.invokeOnCompletion { })) in testCompleteWithIncompleteResult()
34 assertEquals(false, c.complete(c.invokeOnCompletion { })) in testCompleteWithIncompleteResult()
|
| D | LaunchLazyTest.kt | 62 job.invokeOnCompletion { in <lambda>()
|
| D | ExperimentalDispatchModeTest.kt | 49 job.invokeOnCompletion { expect(2) } in <lambda>()
|
| D | WithTimeoutTest.kt | 198 timeoutJob.invokeOnCompletion { } in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | JobStructuredJoinStressTest.kt | 27 job.invokeOnCompletion { cont.resume(Unit) } in <lambda>()
36 job.invokeOnCompletion { cont.resume(Unit) } in <lambda>()
|
| D | JobStressTest.kt | 15 for (i in 0 until n) job.invokeOnCompletion { fireCount++ }.dispose() in testMemoryRelease()
|
| D | JobDisposeStressTest.kt | 42 val handle = job.invokeOnCompletion(onCancelling = true) { /* nothing */ } in <lambda>()
|
| D | JobActivationStressTest.kt | 42 d.invokeOnCompletion { in <lambda>()
|
| D | JobHandlersUpgradeStressTest.kt | 65 … job.invokeOnCompletion(onCancelling = onCancelling, invokeImmediately = invokeImmediately) { in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | NonCancellable.kt | 79 override fun invokeOnCompletion(handler: CompletionHandler): DisposableHandle = in getCancellationException() method
87 …override fun invokeOnCompletion(onCancelling: Boolean, invokeImmediately: Boolean, handler: Comple… in getCancellationException() method
|
| D | Job.kt | 308 public fun invokeOnCompletion(handler: CompletionHandler): DisposableHandle in getCancellationException() method
351 public fun invokeOnCompletion( in getCancellationException() method
493 invokeOnCompletion(handler = DisposeOnCompletion(this, handle).asHandler) in childCancelled()
|
| D | JobSupport.kt | 448 public final override fun invokeOnCompletion(handler: CompletionHandler): DisposableHandle = in <lambda>() method
449 invokeOnCompletion(onCancelling = false, invokeImmediately = true, handler = handler) in <lambda>()
451 public final override fun invokeOnCompletion( in <lambda>() method
556 … cont.disposeOnCancellation(invokeOnCompletion(handler = ResumeOnCompletion(this, cont).asHandler)) in <lambda>()
576 …select.disposeOnSelect(invokeOnCompletion(handler = SelectJoinOnCompletion(this, select, block).as… in <lambda>()
915 val handle = child.childJob.invokeOnCompletion( in <lambda>()
967 …return invokeOnCompletion(onCancelling = true, handler = ChildHandleNode(this, child).asHandler) a… in <lambda>()
1230 … cont.disposeOnCancellation(invokeOnCompletion(ResumeAwaitOnCompletion(this, cont).asHandler)) in <lambda>()
1257 …select.disposeOnSelect(invokeOnCompletion(handler = SelectAwaitOnCompletion(this, select, block).a… in <lambda>()
|
| D | Await.kt | 79 handle = deferred.invokeOnCompletion(asHandler) in await()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/exceptions/ |
| D | SuppressionTests.kt | 41 coroutine.invokeOnCompletion(onCancelling = true) { in <lambda>()
47 coroutine.invokeOnCompletion { in <lambda>()
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-jdk8/src/future/ |
| D | Future.kt | 75 invokeOnCompletion { in asCompletableFuture()
92 invokeOnCompletion { cause -> in asCompletableFuture()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/native/test/ |
| D | RunBlockingTest.kt | 13 coroutineContext[Job]!!.invokeOnCompletion { } in testIncompleteState()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-debug/test/ |
| D | LazyCoroutineTest.kt | 15 job.invokeOnCompletion { expect(2) } in <lambda>()
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-guava/src/ |
| D | ListenableFuture.kt | 152 deferred.invokeOnCompletion { in asDeferred()
350 deferred.invokeOnCompletion { in afterInit()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | Future.kt | 23 …invokeOnCompletion(handler = CancelFutureOnCompletion(this, future)) // TODO make it work only on … in cancelFutureOnCompletion()
|
| D | Interruptible.kt | 97 …cancelHandle = job.invokeOnCompletion(onCancelling = true, invokeImmediately = true, handler = thi… in setup()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/src/ |
| D | Promise.kt | 37 invokeOnCompletion { in <lambda>()
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-play-services/src/ |
| D | Tasks.kt | 28 invokeOnCompletion callback@{ in <lambda>()
|