/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/exceptions/ |
D | StackTraceRecoveryResumeModeTest.kt | 26 withContext(Dispatchers.Unconfined) { in <lambda>() 33 withContext(Dispatchers.Unconfined) { in testNestedUnconfinedChangedContext() 46 withContext(dispatcher) { in <lambda>() 53 withContext(wrapperDispatcher()) { in <lambda>() 70 withContext(context, channel) in doFastPath() 73 private suspend fun withContext(context: CoroutineContext, channel: Channel<Int>) { in withContext() method in kotlinx.coroutines.exceptions.StackTraceRecoveryResumeModeTest 74 withContext(context) { in withContext() 87 withContext(Dispatchers.Unconfined) { in <lambda>() 94 withContext(Dispatchers.Unconfined) { in <lambda>() 107 withContext(dispatcher) { in <lambda>() [all …]
|
D | StackTraceRecoveryCustomExceptionsTest.kt | 33 withContext(wrapperDispatcher(coroutineContext)) { in testStackTraceNotRecovered() 46 withContext(wrapperDispatcher(coroutineContext)) { in <lambda>() 63 withContext(wrapperDispatcher(coroutineContext)) { in <lambda>()
|
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/ |
D | WithContextTest.kt | 18 withContext<Unit>(coroutineContext) { in <lambda>() 34 withContext<Unit>(wrapperDispatcher(coroutineContext)) { in <lambda>() 53 val result = withContext(coroutineContext) { // same context! in <lambda>() 69 val result = withContext(coroutineContext) { // same context! in <lambda>() 88 withContext(coroutineContext + job) { in <lambda>() 118 withContext(coroutineContext + job) { // same context + new job in <lambda>() 141 withContext(job + wrapperDispatcher(coroutineContext)) { in <lambda>() 154 withContext<Unit>(CoroutineName("testRunCancellationUndispatchedVsException")) { in <lambda>() 179 withContext<Unit>(wrapperDispatcher(coroutineContext)) { in <lambda>() 207 withContext<Unit>(wrapperDispatcher(coroutineContext)) { in <lambda>() [all …]
|
D | NonCancellableTest.kt | 14 withContext(NonCancellable) { in <lambda>() 47 withContext(NonCancellable) { in <lambda>() 80 withContext(NonCancellable) { in <lambda>() 107 withContext(NonCancellable) { in <lambda>() 113 withContext(NonCancellable) { in <lambda>()
|
D | UnconfinedTest.kt | 38 withContext(Dispatchers.Unconfined) { in <lambda>() 40 withContext(Dispatchers.Unconfined + CoroutineName("a")) { in <lambda>()
|
D | UndispatchedResultTest.kt | 14 invokeTest { block -> withContext(wrapperDispatcher(coroutineContext), block) } in <lambda>() 19 invokeTest { block -> withContext(coroutineContext, block) } in <lambda>()
|
/external/kotlinx.coroutines/kotlinx-coroutines-test/test/ |
D | TestDispatchersTest.kt | 30 withContext(Dispatchers.Main) { in <lambda>() 35 withContext(Dispatchers.Main) { in <lambda>() 40 withContext(Dispatchers.Main.immediate) { in <lambda>() 46 withContext(Dispatchers.Main.immediate) { in <lambda>() 57 withContext(Dispatchers.Main) { in <lambda>() 62 withContext(Dispatchers.Main) { in <lambda>()
|
D | TestCoroutineDispatcherTest.kt | 112 withContext(subject) { in whenDispatchCalled_runsOnCurrentThread() 131 withContext(subject) { in whenAllDispatchersMocked_runsOnSameThread()
|
/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>()
|
D | CombineStressTest.kt | 14 withContext(Dispatchers.Default + CoroutineExceptionHandler { _, _ -> expectUnreached() }) { in <lambda>() 32 withContext(Dispatchers.Default + CoroutineExceptionHandler { _, _ -> expectUnreached() }) { in <lambda>()
|
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
D | ThreadLocalTest.kt | 30 withContext(executor) { in <lambda>() 51 withContext(executor) { in <lambda>() 72 withContext(executor) { in <lambda>() 95 withContext(executor + intThreadLocal.asContextElement(42)) { in <lambda>() 130 withContext(executor + stringThreadLocal.asContextElement("ctx")) { in <lambda>() 163 withContext(executor + myCounterLocal.asContextElement(Counter(-1))) { in <lambda>() 196 withContext(it + intThreadLocal.asContextElement(2)) { in <lambda>()
|
D | RejectedExecutionTest.kt | 53 withContext(executor.asCoroutineDispatcher()) { in <lambda>() 66 withContext(executor.asCoroutineDispatcher()) { in <lambda>() 70 withContext(Dispatchers.Default) { in <lambda>() 97 withContext(executor.asCoroutineDispatcher()) { in <lambda>() 119 withContext(executor.asCoroutineDispatcher()) { in <lambda>()
|
D | WithDefaultContextTest.kt | 13 val result = withContext(Dispatchers.Default) { in <lambda>() 24 val result = withContext(Dispatchers.Default) { in <lambda>()
|
D | DebugThreadNameTest.kt | 51 withContext(Dispatchers.Default) { in <lambda>() 55 withContext(CoroutineName("TEST")) { in <lambda>()
|
D | ThreadContextElementTest.kt | 25 withContext(mainDispatcher) { in <lambda>() 73 withContext(it + MyElement(newData)) { 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>() 58 withContext(Dispatchers.Default) { in <lambda>()
|
D | RunningThreadStackMergeTest.kt | 59 withContext(Dispatchers.IO) { in suspendingFunction() 106 withContext(Dispatchers.IO) { in suspendingFunctionWithContext()
|
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/ |
D | FlowInvariantsTest.kt | 42 withContext(NonCancellable) { in <lambda>() 53 withContext(NamedDispatchers("foo")) { in <lambda>() 64 withContext(CoroutineName("foo")) { in <lambda>() 79 withContext(NamedDispatchers("misc")) { in <lambda>() 231 withContext(Dispatchers.Unconfined) { in <lambda>() 249 withContext(Dispatchers.Unconfined) { in <lambda>()
|
D | VirtualTime.kt | 83 withContext(Dispatchers.Unconfined) { in deadline() 86 withContext(dispatcher) { block() } in deadline()
|
/external/kotlinx.coroutines/integration/kotlinx-coroutines-slf4j/test/ |
D | MDCContextTest.kt | 54 withContext(MDCContext()) { in <lambda>() 103 withContext(Dispatchers.Default + MDCContext()) { in <lambda>() 105 withContext(mainDispatcher) { in <lambda>()
|
/external/kotlinx.coroutines/kotlinx-coroutines-core/js/test/ |
D | ImmediateDispatcherTest.kt | 15 withContext(Dispatchers.Main.immediate) { in testImmediate() 26 withContext(Dispatchers.Main) { in <lambda>()
|
D | SetTimeoutDispatcherTest.kt | 26 withContext(SetTimeoutDispatcher) { in <lambda>() 42 withContext(SetTimeoutDispatcher) { in <lambda>()
|
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/guide/ |
D | example-sync-04.kt | 30 withContext(Dispatchers.Default) { in <lambda>() 33 withContext(counterContext) { in <lambda>()
|
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/ |
D | SharingWorkerClassTest.kt | 20 withContext(dispatcher) { in <lambda>() 23 withContext(dispatcher2) { in <lambda>()
|
D | CoroutineDispatcherTest.kt | 24 withContext(dispatcher) { in <lambda>() 80 withContext(dispatcher) { in <lambda>()
|