| /external/kotlinx.coroutines/kotlinx-coroutines-test/test/ |
| D | TestDispatchersTest.kt | 17 Dispatchers.resetMain() in <lambda>()
22 Dispatchers.setMain(Dispatchers.Main) in <lambda>()
28 Dispatchers.setMain(Dispatchers.Unconfined) in <lambda>()
30 withContext(Dispatchers.Main) { in <lambda>()
34 Dispatchers.setMain(threadPool) in <lambda>()
35 withContext(Dispatchers.Main) { in <lambda>()
40 withContext(Dispatchers.Main.immediate) { in <lambda>()
45 Dispatchers.setMain(Dispatchers.Unconfined) in <lambda>()
46 withContext(Dispatchers.Main.immediate) { in <lambda>()
55 Dispatchers.setMain(ImmediateDispatcher()) in <lambda>()
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/ |
| D | CoroutineScopeTest.kt | 256 … assertSame(Dispatchers.Default, scopePlusContext(EmptyCoroutineContext, Dispatchers.Default)) in testScopePlusContext()
257 … assertSame(Dispatchers.Default, scopePlusContext(Dispatchers.Default, EmptyCoroutineContext)) in testScopePlusContext()
258 assertSame(Dispatchers.Default, scopePlusContext(Dispatchers.Default, Dispatchers.Default)) in testScopePlusContext()
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 | UnconfinedTest.kt | 14 launch(Dispatchers.Unconfined) { in <lambda>()
38 withContext(Dispatchers.Unconfined) { in <lambda>()
40 withContext(Dispatchers.Unconfined + CoroutineName("a")) { 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 | JobExtensionsTest.kt | 18 scope.launch(Dispatchers.Unconfined) { in <lambda>()
37 scope.launch(Dispatchers.Unconfined) { in <lambda>()
57 scope.launch(Dispatchers.Unconfined) { in <lambda>()
92 assertFailsWith<IllegalStateException> { Dispatchers.Default.job } in <lambda>()
93 assertFailsWith<IllegalStateException> { (Dispatchers.Default + CoroutineName("")).job } in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-debug/test/ |
| D | BlockHoundTest.kt | 16 withContext(Dispatchers.Default) { in <lambda>()
23 withContext(Dispatchers.IO) { in <lambda>()
30 withContext(Dispatchers.Default) { in <lambda>()
41 async(Dispatchers.IO) { in <lambda>()
46 async(Dispatchers.Default) { in <lambda>()
50 async(Dispatchers.IO) { in <lambda>()
58 withContext(Dispatchers.Default) { in <lambda>()
81 async(Dispatchers.IO) { in <lambda>()
85 async(Dispatchers.Default) { in <lambda>()
89 async(Dispatchers.IO) { in <lambda>()
|
| D | RunningThreadStackMergeTest.kt | 51 launch(Dispatchers.Default) { in CoroutineScope()
59 withContext(Dispatchers.IO) { in suspendingFunction()
99 launch(Dispatchers.Default) { in CoroutineScope()
106 withContext(Dispatchers.IO) { in suspendingFunctionWithContext()
138 launch(Dispatchers.IO) { in CoroutineScope()
|
| /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>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | FailFastOnStartTest.kt | 23 launch(Dispatchers.Main) {} in <lambda>()
28 val job = launch(Dispatchers.Main, start = CoroutineStart.LAZY) { fail() } in <lambda>()
34 launch(Dispatchers.Main, start = CoroutineStart.UNDISPATCHED) { in <lambda>()
42 async(Dispatchers.Main) {} in <lambda>()
47 val job = async(Dispatchers.Main, start = CoroutineStart.LAZY) { fail() } in testAsyncLazy()
53 withContext(Dispatchers.Main) { in <lambda>()
60 produce<Int>(Dispatchers.Main) { fail() } in <lambda>()
65 actor<Int>(Dispatchers.Main) { fail() } in <lambda>()
70 val actor = actor<Int>(Dispatchers.Main, start = CoroutineStart.LAZY) { fail() } in <lambda>()
|
| D | DispatcherKeyTest.kt | 29 val updated = context + Dispatchers.Main in testDispatcher()
31 assertSame(Dispatchers.Main, result) in testDispatcher()
32 assertSame(Dispatchers.Main, updated[ContinuationInterceptor]) in testDispatcher()
41 val updated = context + Dispatchers.Main in testExecutorCoroutineDispatcher()
43 val executor = Dispatchers.Default in testExecutorCoroutineDispatcher()
45 assertSame(Dispatchers.Default, updated2[ContinuationInterceptor]) in testExecutorCoroutineDispatcher()
46 assertSame(Dispatchers.Default, updated2[CoroutineDispatcher]) in testExecutorCoroutineDispatcher()
47 …assertSame(Dispatchers.Default as ExecutorCoroutineDispatcher, updated2[ExecutorCoroutineDispatche… in testExecutorCoroutineDispatcher()
|
| D | DispatchersToStringTest.kt | 12 assertEquals("Dispatchers.Unconfined", Dispatchers.Unconfined.toString()) in testStrings()
13 assertEquals("Dispatchers.Default", Dispatchers.Default.toString()) in testStrings()
14 assertEquals("Dispatchers.IO", Dispatchers.IO.toString()) in testStrings()
15 assertEquals("Dispatchers.Main[missing]", Dispatchers.Main.toString()) in testStrings()
16 assertEquals("Dispatchers.Main[missing]", Dispatchers.Main.immediate.toString()) in testStrings()
|
| /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>()
|
| /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/ui/kotlinx-coroutines-javafx/test/ |
| D | JavaFxDispatcherTest.kt | 28 val job = launch(Dispatchers.JavaFx) { in testDelay()
47 runBlocking(Dispatchers.JavaFx) { in testImmediateDispatcherYield()
51 launch(Dispatchers.JavaFx.immediate) { in testImmediateDispatcherYield()
64 assertEquals("Dispatchers.Main", Dispatchers.Main.toString()) in testMainDispatcherToString()
65 assertEquals("Dispatchers.Main.immediate", Dispatchers.Main.immediate.toString()) in testMainDispatcherToString()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-test/src/ |
| D | TestDispatchers.kt | 19 public fun Dispatchers.setMain(dispatcher: CoroutineDispatcher) { in setMain()
21 val mainDispatcher = Dispatchers.Main in setMain()
34 public fun Dispatchers.resetMain() { in resetMain()
35 val mainDispatcher = Dispatchers.Main in resetMain()
|
| /external/kotlinx.coroutines/ui/kotlinx-coroutines-android/android-unit-tests/test/ordered/tests/ |
| D | FirstMockedMainTest.kt | 18 Dispatchers.setMain(Dispatchers.Unconfined) in setUp()
23 Dispatchers.resetMain() in tearDown()
35 Dispatchers.resetMain() in testFailureWhenReset()
|
| D | CustomizedRobolectricTest.kt | 22 GlobalScope.launch(Dispatchers.Main + CoroutineExceptionHandler { _, _ -> }) { } in <lambda>()
41 Dispatchers.setMain(Dispatchers.Unconfined) in testComponentAfterReset()
42 Dispatchers.resetMain() in testComponentAfterReset()
|
| /external/kotlinx.coroutines/ui/kotlinx-coroutines-javafx/ |
| D | README.md | 3 Provides `Dispatchers.JavaFx` context and `Dispatchers.Main` implementation for JavaFX UI applicati…
10 Provides `Dispatchers.JavaFx` context and `Dispatchers.Main` implementation for JavaFX UI applicati…
|
| /external/kotlinx.coroutines/ui/kotlinx-coroutines-swing/ |
| D | README.md | 3 Provides `Dispatchers.Swing` context and `Dispatchers.Main` implementation for Swing UI application…
10 Provides `Dispatchers.Swing` context and `Dispatchers.Main` implementation for Swing UI applicatio…
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/flow/ |
| D | FlatMapStressTest.kt | 22 withContext(Dispatchers.Default) { in <lambda>()
29 withContext(Dispatchers.Default) { in <lambda>()
37 withContext(Dispatchers.Default) { in <lambda>()
62 withContext(Dispatchers.Default) { in <lambda>()
74 withContext(Dispatchers.Default) { in <lambda>()
|