| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/ |
| D | UnconfinedTest.kt | 14 launch(Dispatchers.Unconfined) { in <lambda>()
38 withContext(Dispatchers.Unconfined) { in <lambda>()
40 withContext(Dispatchers.Unconfined + CoroutineName("a")) { in <lambda>()
58 launch(Unconfined) { in <lambda>()
62 launch(Unconfined) { in <lambda>()
66 launch(Unconfined) { in <lambda>()
76 launch(Dispatchers.Unconfined) { in <lambda>()
93 GlobalScope.launch(Dispatchers.Unconfined) { in <lambda>()
97 GlobalScope.launch(Dispatchers.Unconfined) { in <lambda>()
|
| D | ExperimentalDispatchModeTest.kt | 16 launch(Dispatchers.Unconfined) { in <lambda>()
30 val job = launch(Dispatchers.Unconfined) { in <lambda>()
46 val job = launch(Dispatchers.Unconfined, start = CoroutineStart.LAZY) { in <lambda>()
80 launch(Dispatchers.Unconfined, start = CoroutineStart.ATOMIC) { in <lambda>()
96 withContext(Dispatchers.Unconfined) { in <lambda>()
|
| D | CoroutineScopeTest.kt | 259 … assertSame(Dispatchers.Default, scopePlusContext(Dispatchers.Unconfined, Dispatchers.Default)) in testScopePlusContext()
260 … assertSame(Dispatchers.Unconfined, scopePlusContext(Dispatchers.Default, Dispatchers.Unconfined)) in testScopePlusContext()
261 …assertSame(Dispatchers.Unconfined, scopePlusContext(Dispatchers.Unconfined, Dispatchers.Unconfined… in testScopePlusContext()
|
| D | JobExtensionsTest.kt | 18 scope.launch(Dispatchers.Unconfined) { in <lambda>()
37 scope.launch(Dispatchers.Unconfined) { in <lambda>()
57 scope.launch(Dispatchers.Unconfined) { in <lambda>()
|
| D | ImmediateYieldTest.kt | 39 launch(wrapperDispatcher(Dispatchers.Unconfined)) { in isDispatchNeeded()
50 withContext(wrapperDispatcher(Dispatchers.Unconfined)) { in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| D | ConvertTest.kt | 52 val maybe1 = d.asMaybe(Dispatchers.Unconfined) in <lambda>()
56 val maybe2 = d.asMaybe(Dispatchers.Unconfined) in <lambda>()
68 val maybe1 = d.asMaybe(Dispatchers.Unconfined) in <lambda>()
70 val maybe2 = d.asMaybe(Dispatchers.Unconfined) in <lambda>()
80 val maybe1 = d.asMaybe(Dispatchers.Unconfined) in <lambda>()
84 val maybe2 = d.asMaybe(Dispatchers.Unconfined) in <lambda>()
96 val single1 = d.asSingle(Dispatchers.Unconfined) in <lambda>()
100 val single2 = d.asSingle(Dispatchers.Unconfined) in <lambda>()
112 val single1 = d.asSingle(Dispatchers.Unconfined) in <lambda>()
116 val single2 = d.asSingle(Dispatchers.Unconfined) in <lambda>()
[all …]
|
| D | FlowableExceptionHandlingTest.kt | 29 rxFlowable<Int>(Dispatchers.Unconfined + cehUnreached()) { in <lambda>()
42 rxFlowable<Int>(Dispatchers.Unconfined) { in <lambda>()
55 rxFlowable<Int>(Dispatchers.Unconfined + cehUnreached()) { in <lambda>()
70 rxFlowable<Int>(Dispatchers.Unconfined) { in <lambda>()
85 rxFlowable(Dispatchers.Unconfined) { in <lambda>()
97 rxFlowable(Dispatchers.Unconfined + cehUnreached()) { in <lambda>()
109 rxFlowable(Dispatchers.Unconfined + cehUnreached()) { in <lambda>()
123 rxFlowable(Dispatchers.Unconfined) { in <lambda>()
|
| D | ObservableExceptionHandlingTest.kt | 29 rxObservable<Int>(Dispatchers.Unconfined + cehUnreached()) { in <lambda>()
42 rxObservable<Int>(Dispatchers.Unconfined) { in <lambda>()
55 rxObservable<Int>(Dispatchers.Unconfined) { in <lambda>()
70 rxObservable<Int>(Dispatchers.Unconfined) { in <lambda>()
85 rxObservable(Dispatchers.Unconfined) { in <lambda>()
97 rxObservable(Dispatchers.Unconfined) { in <lambda>()
109 rxObservable(Dispatchers.Unconfined) { in <lambda>()
123 rxObservable(Dispatchers.Unconfined) { in <lambda>()
|
| D | ObservableAsFlowTest.kt | 34 source.asFlow().launchIn(CoroutineScope(Dispatchers.Unconfined)) { in testCancellation()
54 GlobalScope.launch(Dispatchers.Unconfined) { in testImmediateCollection()
72 GlobalScope.launch(Dispatchers.Unconfined) { in testOnErrorCancellation()
96 GlobalScope.launch(Dispatchers.Unconfined) { in testUnsubscribeOnCollectionException()
124 val job = GlobalScope.launch(Dispatchers.Unconfined) { in testLateOnSubscribe()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| D | ConvertTest.kt | 52 val maybe1 = d.asMaybe(Dispatchers.Unconfined) in <lambda>()
56 val maybe2 = d.asMaybe(Dispatchers.Unconfined) in <lambda>()
68 val maybe1 = d.asMaybe(Dispatchers.Unconfined) in <lambda>()
70 val maybe2 = d.asMaybe(Dispatchers.Unconfined) in <lambda>()
80 val maybe1 = d.asMaybe(Dispatchers.Unconfined) in <lambda>()
84 val maybe2 = d.asMaybe(Dispatchers.Unconfined) in <lambda>()
96 val single1 = d.asSingle(Dispatchers.Unconfined) in <lambda>()
100 val single2 = d.asSingle(Dispatchers.Unconfined) in <lambda>()
112 val single1 = d.asSingle(Dispatchers.Unconfined) in <lambda>()
116 val single2 = d.asSingle(Dispatchers.Unconfined) in <lambda>()
[all …]
|
| D | FlowableExceptionHandlingTest.kt | 29 rxFlowable<Int>(Dispatchers.Unconfined + cehUnreached()) { in <lambda>()
42 rxFlowable<Int>(Dispatchers.Unconfined) { in <lambda>()
55 rxFlowable<Int>(Dispatchers.Unconfined + cehUnreached()) { in <lambda>()
70 rxFlowable<Int>(Dispatchers.Unconfined) { in <lambda>()
85 rxFlowable(Dispatchers.Unconfined) { in <lambda>()
97 rxFlowable(Dispatchers.Unconfined + cehUnreached()) { in <lambda>()
109 rxFlowable(Dispatchers.Unconfined + cehUnreached()) { in <lambda>()
123 rxFlowable(Dispatchers.Unconfined) { in <lambda>()
|
| D | ObservableExceptionHandlingTest.kt | 29 rxObservable<Int>(Dispatchers.Unconfined + cehUnreached()) { in <lambda>()
42 rxObservable<Int>(Dispatchers.Unconfined) { in <lambda>()
55 rxObservable<Int>(Dispatchers.Unconfined) { in <lambda>()
70 rxObservable<Int>(Dispatchers.Unconfined) { in <lambda>()
85 rxObservable(Dispatchers.Unconfined) { in <lambda>()
97 rxObservable(Dispatchers.Unconfined) { in <lambda>()
109 rxObservable(Dispatchers.Unconfined) { in <lambda>()
123 rxObservable(Dispatchers.Unconfined) { in <lambda>()
|
| D | ObservableAsFlowTest.kt | 34 source.asFlow().launchIn(CoroutineScope(Dispatchers.Unconfined)) { in testCancellation()
54 GlobalScope.launch(Dispatchers.Unconfined) { in testImmediateCollection()
72 GlobalScope.launch(Dispatchers.Unconfined) { in testOnErrorCancellation()
96 GlobalScope.launch(Dispatchers.Unconfined) { in testUnsubscribeOnCollectionException()
124 val job = GlobalScope.launch(Dispatchers.Unconfined) { in testLateOnSubscribe()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/test/ |
| D | ConvertTest.kt | 53 val mono1 = d.asMono(Dispatchers.Unconfined) in <lambda>()
57 val mono2 = d.asMono(Dispatchers.Unconfined) in <lambda>()
69 val mono1 = d.asMono(Dispatchers.Unconfined) in <lambda>()
71 val mono2 = d.asMono(Dispatchers.Unconfined) in <lambda>()
81 val mono1 = d.asMono(Dispatchers.Unconfined) in <lambda>()
85 val mono2 = d.asMono(Dispatchers.Unconfined) in <lambda>()
99 val flux = c.asFlux(Dispatchers.Unconfined) in <lambda>()
113 val flux = c.asFlux(Dispatchers.Unconfined) in <lambda>()
114 val mono = mono(Dispatchers.Unconfined) { in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/exceptions/ |
| D | StackTraceRecoveryResumeModeTest.kt | 21 testResumeModeFastPath(Dispatchers.Unconfined) in <lambda>()
26 withContext(Dispatchers.Unconfined) { in <lambda>()
27 testResumeModeFastPath(Dispatchers.Unconfined) in <lambda>()
33 withContext(Dispatchers.Unconfined) { in testNestedUnconfinedChangedContext()
82 testResumeModeSuspending(Dispatchers.Unconfined) in <lambda>()
87 withContext(Dispatchers.Unconfined) { in <lambda>()
88 testResumeModeSuspending(Dispatchers.Unconfined) in <lambda>()
94 withContext(Dispatchers.Unconfined) { in <lambda>()
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/ |
| D | ChannelSinkBenchmark.kt | 23 private val unconfined = Dispatchers.Unconfined in <lambda>()
24 private val unconfinedOneElement = Dispatchers.Unconfined + tl.asContextElement() in <lambda>()
25 …private val unconfinedTwoElements = Dispatchers.Unconfined + tl.asContextElement() + tl2.asContext… in <lambda>()
56 …private fun <E> ReceiveChannel<E>.filter(context: CoroutineContext = Dispatchers.Unconfined, predi… in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | EventLoopsTest.kt | 33 launch(Dispatchers.Unconfined) { in testUnconfinedInRunBlocking()
44 GlobalScope.launch(Dispatchers.Unconfined) { in testNestedUnconfined()
46 GlobalScope.launch(Dispatchers.Unconfined) { in testNestedUnconfined()
58 withContext(Dispatchers.Unconfined) { in <lambda>()
|
| D | UnconfinedConcurrentStressTest.kt | 33 launch(Dispatchers.Unconfined) { in <lambda>()
35 launch(Dispatchers.Unconfined) { in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | Dispatchers.kt | 94 public actual val Unconfined: CoroutineDispatcher = kotlinx.coroutines.Unconfined constant
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/ |
| D | Dispatchers.kt | 12 …public actual val Unconfined: CoroutineDispatcher get() = kotlinx.coroutines.Unconfined // Avoid f… constant
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/src/ |
| D | Dispatchers.kt | 12 public actual val Unconfined: CoroutineDispatcher = kotlinx.coroutines.Unconfined constant
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-jdk8/test/future/ |
| D | FutureTest.kt | 330 val result = future<Int>(Dispatchers.Unconfined) { in <lambda>()
340 val result = future(Dispatchers.Unconfined) { in <lambda>()
352 val result = future(Dispatchers.Unconfined) { in <lambda>()
365 val result = future(Dispatchers.Unconfined) { in <lambda>()
382 val result = future(Dispatchers.Unconfined) { in <lambda>()
402 val result = future(NonCancellable + Dispatchers.Unconfined) { in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
| D | Channels.common.kt | 690 public fun <E> ReceiveChannel<E>.drop(n: Int, context: CoroutineContext = Dispatchers.Unconfined): … in drop()
718 public fun <E> ReceiveChannel<E>.dropWhile(context: CoroutineContext = Dispatchers.Unconfined, pred… in dropWhile()
744 public fun <E> ReceiveChannel<E>.filter(context: CoroutineContext = Dispatchers.Unconfined, predica… in filter()
766 public fun <E> ReceiveChannel<E>.filterIndexed(context: CoroutineContext = Dispatchers.Unconfined, … in filterIndexed()
831 public fun <E> ReceiveChannel<E>.filterNot(context: CoroutineContext = Dispatchers.Unconfined, pred… in filterNot()
984 public fun <E> ReceiveChannel<E>.take(n: Int, context: CoroutineContext = Dispatchers.Unconfined): … in take()
1010 public fun <E> ReceiveChannel<E>.takeWhile(context: CoroutineContext = Dispatchers.Unconfined, pred… in takeWhile()
1284 public fun <E, R> ReceiveChannel<E>.flatMap(context: CoroutineContext = Dispatchers.Unconfined, tra… in toMutableList()
1392 public fun <E, R> ReceiveChannel<E>.map(context: CoroutineContext = Dispatchers.Unconfined, transfo… in map()
1415 public fun <E, R> ReceiveChannel<E>.mapIndexed(context: CoroutineContext = Dispatchers.Unconfined, … in mapIndexed()
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-test/test/ |
| D | TestDispatchersTest.kt | 28 Dispatchers.setMain(Dispatchers.Unconfined) in <lambda>()
45 Dispatchers.setMain(Dispatchers.Unconfined) in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/channels/ |
| D | ConflatedBroadcastChannelTest.kt | 18 val job1 = launch(Dispatchers.Unconfined, CoroutineStart.UNDISPATCHED) { in <lambda>()
24 val job2 = launch(Dispatchers.Unconfined, CoroutineStart.UNDISPATCHED) { in <lambda>()
|