| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/operators/ |
| D | OnCompletionTest.kt | 21 }.onCompletion { in <lambda>()
35 }.onCompletion { in <lambda>()
52 }.onCompletion { in <lambda>()
67 flowOf(1).onCompletion { in <lambda>()
73 }.onCompletion { in <lambda>()
88 }.onCompletion { in <lambda>()
100 flowOf(1).onCompletion { in <lambda>()
120 .onCompletion() { emit("Done") } in <lambda>()
145 .onCompletion { e -> in <lambda>()
172 .onCompletion { e -> in <lambda>()
[all …]
|
| D | FlatMapMergeTest.kt | 49 .onCompletion { expect(5) } in <lambda>()
52 flowOf(it).onCompletion { expectUnreached() } } in <lambda>()
53 .onCompletion { expect(6) } in <lambda>()
|
| D | FlowOnTest.kt | 288 .onCompletion { expect(4) } in <lambda>()
290 .onCompletion { expect(5) } in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
| D | Produce.kt | 99 …produce(context, capacity, BufferOverflow.SUSPEND, CoroutineStart.DEFAULT, onCompletion = null, bl… in produce()
118 onCompletion: CompletionHandler? = null, in produce()
121 produce(context, capacity, BufferOverflow.SUSPEND, start, onCompletion, block) in produce()
129 onCompletion: CompletionHandler? = null, in produce()
135 if (onCompletion != null) coroutine.invokeOnCompletion(handler = onCompletion) in produce()
|
| D | Broadcast.kt | 50 …return scope.broadcast(capacity = capacity, start = start, onCompletion = { cancelConsumed(it) }) { in <lambda>()
113 onCompletion: CompletionHandler? = null, in broadcast()
121 if (onCompletion != null) coroutine.invokeOnCompletion(handler = onCompletion) in broadcast()
|
| D | Channels.common.kt | 691 GlobalScope.produce(context, onCompletion = consumes()) { in drop()
719 GlobalScope.produce(context, onCompletion = consumes()) { in dropWhile()
745 GlobalScope.produce(context, onCompletion = consumes()) { in filter()
767 GlobalScope.produce(context, onCompletion = consumes()) { in filterIndexed()
985 GlobalScope.produce(context, onCompletion = consumes()) { in take()
1011 GlobalScope.produce(context, onCompletion = consumes()) { in takeWhile()
1285 GlobalScope.produce(context, onCompletion = consumes()) { in toMutableList()
1393 GlobalScope.produce(context, onCompletion = consumes()) { in map()
1416 GlobalScope.produce(context, onCompletion = consumes()) { in mapIndexed()
1651 GlobalScope.produce(context, onCompletion = consumes()) { in withIndex()
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/channels/ |
| D | Actor.kt | 113 onCompletion: CompletionHandler? = null, in actor()
121 if (onCompletion != null) coroutine.invokeOnCompletion(handler = onCompletion) in actor()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/terminal/ |
| D | LaunchInTest.kt | 21 }.onCompletion { in <lambda>()
50 }.onCompletion { in <lambda>()
|
| /external/kotlinx.atomicfu/atomicfu/src/jvmMain/kotlin/kotlinx/atomicfu/ |
| D | LockFreedomTestEnvironment.kt | 40 private val onCompletion = mutableListOf<() -> Unit>() in <lambda>() constant in kotlinx.atomicfu.LockFreedomTestEnvironment
103 onCompletion.forEach { it() } in <lambda>()
194 public fun onCompletion(block: () -> Unit) { in <lambda>() method in kotlinx.atomicfu.LockFreedomTestEnvironment
195 onCompletion += block in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/guide/ |
| D | example-flow-32.kt | 15 .onCompletion { println("Done") } in <lambda>()
|
| D | example-flow-34.kt | 15 .onCompletion { cause -> println("Flow completed with $cause") } in <lambda>()
|
| D | example-flow-33.kt | 18 .onCompletion { cause -> if (cause != null) println("Flow completed exceptionally") } in <lambda>()
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/scheduler/ |
| D | ForkJoinBenchmark.kt | 150 override fun onCompletion(caller: CountedCompleter<*>?) { in onCompletion() method in benchmarks.scheduler.ForkJoinBenchmark
154 super.onCompletion(caller) in onCompletion()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-debug/test/ |
| D | DebugTestBase.kt | 30 onCompletion() in tearDown()
|
| D | ToStringTest.kt | 28 onCompletion() in tearDown()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/flow/ |
| D | OnCompletionInterceptedReleaseTest.kt | 20 .onCompletion { emit(1) } in <lambda>()
|
| D | SharingStressTest.kt | 157 .onCompletion { in <lambda>()
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/ |
| D | ChannelSinkBenchmark.kt | 57 GlobalScope.produce(context, onCompletion = { cancel() }) { in <lambda>()
|
| /external/robolectric-shadows/robolectric/src/test/java/org/robolectric/shadows/ |
| D | ShadowMediaPlayerTest.java | 297 Mockito.verify(completionListener).onCompletion(mediaPlayer); in testPlaybackProgress()
334 Mockito.verify(completionListener).onCompletion(mediaPlayer); in testPauseReschedulesCompletionCallback()
370 Mockito.verify(completionListener).onCompletion(mediaPlayer); in testSeekDuringPlaybackReschedulesCompletionCallback()
867 Mockito.verify(completionListener).onCompletion(mediaPlayer); in testCompletionListener()
998 Mockito.verify(completionListener).onCompletion(mediaPlayer); in testSeekWhileSeekingWhilePlaying()
1126 Mockito.verify(completionListener).onCompletion(mediaPlayer); in testErrorListenerCalledOnCompleteCalledWhenReturnFalse()
1136 Mockito.verify(completionListener).onCompletion(mediaPlayer); in testErrorCausesOnCompleteCalledWhenNoErrorListener()
1376 Mockito.verify(completionListener).onCompletion(mediaPlayer); in testSetLoopingCalledWhilePlaying()
|
| D | ShadowVideoViewTest.java | 161 public void onCompletion(MediaPlayer mp) {} in onCompletion() method in ShadowVideoViewTest.TestCompletionListener
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/channels/ |
| D | ChannelLFStressTest.kt | 45 env.onCompletion { in performLockFreedomTest()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/operators/ |
| D | Emitters.kt | 144 public fun <T> Flow<T>.onCompletion( in onCompletion() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/selects/ |
| D | SelectDeadlockLFStressTest.kt | 35 env.onCompletion { in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/channels/ |
| D | ProduceTest.kt | 166 … val produced = produce<Int>(coroutineContext, onCompletion = { source.cancelConsumed(it) }) { in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | TestBase.kt | 149 fun onCompletion() { in <lambda>() method
|