Home
last modified time | relevance | path

Searched refs:withContext (Results 1 – 25 of 115) sorted by relevance

12345

/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/exceptions/
DStackTraceRecoveryResumeModeTest.kt26 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 …]
DStackTraceRecoveryCustomExceptionsTest.kt33 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/
DWithContextTest.kt18 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 …]
DNonCancellableTest.kt14 withContext(NonCancellable) { in <lambda>()
47 withContext(NonCancellable) { in <lambda>()
80 withContext(NonCancellable) { in <lambda>()
107 withContext(NonCancellable) { in <lambda>()
113 withContext(NonCancellable) { in <lambda>()
DUnconfinedTest.kt38 withContext(Dispatchers.Unconfined) { in <lambda>()
40 withContext(Dispatchers.Unconfined + CoroutineName("a")) { in <lambda>()
DUndispatchedResultTest.kt14 invokeTest { block -> withContext(wrapperDispatcher(coroutineContext), block) } in <lambda>()
19 invokeTest { block -> withContext(coroutineContext, block) } in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-test/test/
DTestDispatchersTest.kt30 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>()
DTestCoroutineDispatcherTest.kt112 withContext(subject) { in whenDispatchCalled_runsOnCurrentThread()
131 withContext(subject) { in whenAllDispatchersMocked_runsOnSameThread()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/flow/
DFlatMapStressTest.kt22 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>()
DCombineStressTest.kt14 withContext(Dispatchers.Default + CoroutineExceptionHandler { _, _ -> expectUnreached() }) { in <lambda>()
32 withContext(Dispatchers.Default + CoroutineExceptionHandler { _, _ -> expectUnreached() }) { in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/
DThreadLocalTest.kt30 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>()
DRejectedExecutionTest.kt53 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>()
DWithDefaultContextTest.kt13 val result = withContext(Dispatchers.Default) { in <lambda>()
24 val result = withContext(Dispatchers.Default) { in <lambda>()
DDebugThreadNameTest.kt51 withContext(Dispatchers.Default) { in <lambda>()
55 withContext(CoroutineName("TEST")) { in <lambda>()
DThreadContextElementTest.kt25 withContext(mainDispatcher) { in <lambda>()
73 withContext(it + MyElement(newData)) { in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-debug/test/
DBlockHoundTest.kt16 withContext(Dispatchers.Default) { in <lambda>()
23 withContext(Dispatchers.IO) { in <lambda>()
30 withContext(Dispatchers.Default) { in <lambda>()
58 withContext(Dispatchers.Default) { in <lambda>()
DRunningThreadStackMergeTest.kt59 withContext(Dispatchers.IO) { in suspendingFunction()
106 withContext(Dispatchers.IO) { in suspendingFunctionWithContext()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/
DFlowInvariantsTest.kt42 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>()
DVirtualTime.kt83 withContext(Dispatchers.Unconfined) { in deadline()
86 withContext(dispatcher) { block() } in deadline()
/external/kotlinx.coroutines/integration/kotlinx-coroutines-slf4j/test/
DMDCContextTest.kt54 withContext(MDCContext()) { in <lambda>()
103 withContext(Dispatchers.Default + MDCContext()) { in <lambda>()
105 withContext(mainDispatcher) { in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/js/test/
DImmediateDispatcherTest.kt15 withContext(Dispatchers.Main.immediate) { in testImmediate()
26 withContext(Dispatchers.Main) { in <lambda>()
DSetTimeoutDispatcherTest.kt26 withContext(SetTimeoutDispatcher) { in <lambda>()
42 withContext(SetTimeoutDispatcher) { in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/guide/
Dexample-sync-04.kt30 withContext(Dispatchers.Default) { in <lambda>()
33 withContext(counterContext) { in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/
DSharingWorkerClassTest.kt20 withContext(dispatcher) { in <lambda>()
23 withContext(dispatcher2) { in <lambda>()
DCoroutineDispatcherTest.kt24 withContext(dispatcher) { in <lambda>()
80 withContext(dispatcher) { in <lambda>()

12345