| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/ |
| D | WithContextTest.kt | 31 withContext<Unit>(wrapperDispatcher(coroutineContext)) { in <lambda>()
138 withContext(job + wrapperDispatcher(coroutineContext)) { in <lambda>()
176 withContext<Unit>(wrapperDispatcher(coroutineContext)) { in <lambda>()
204 withContext<Unit>(wrapperDispatcher(coroutineContext)) { in <lambda>()
233 withContext(wrapperDispatcher(coroutineContext)) { in <lambda>()
261 withContext(wrapperDispatcher(coroutineContext)) { in <lambda>()
297 withContext(wrapperDispatcher(coroutineContext)) { in <lambda>()
312 withContext(wrapperDispatcher(coroutineContext)) { in <lambda>()
343 withContext(wrapperDispatcher(coroutineContext)) { in <lambda>()
353 withContext(wrapperDispatcher()) { in <lambda>()
|
| D | ImmediateYieldTest.kt | 36 launch(wrapperDispatcher(Dispatchers.Unconfined)) { in isDispatchNeeded()
47 withContext(wrapperDispatcher(Dispatchers.Unconfined)) { in <lambda>()
|
| D | UndispatchedResultTest.kt | 11 invokeTest { block -> withContext(wrapperDispatcher(coroutineContext), block) } in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/exceptions/ |
| D | StackTraceRecoveryResumeModeTest.kt | 37 testResumeModeFastPath(wrapperDispatcher()) in <lambda>()
42 val dispatcher = wrapperDispatcher() in <lambda>()
50 withContext(wrapperDispatcher()) { in <lambda>()
98 testResumeModeSuspending(wrapperDispatcher()) in <lambda>()
103 val dispatcher = wrapperDispatcher() in <lambda>()
111 withContext(wrapperDispatcher()) { in <lambda>()
|
| D | StackTraceRecoveryCustomExceptionsTest.kt | 31 withContext(wrapperDispatcher(coroutineContext)) { in testStackTraceNotRecovered()
44 withContext(wrapperDispatcher(coroutineContext)) { in <lambda>()
61 withContext(wrapperDispatcher(coroutineContext)) { in <lambda>()
|
| D | WithContextExceptionHandlingTest.kt | 196 private fun wrapperDispatcher(context: CoroutineContext): CoroutineContext { in <lambda>() method
213 withCtx(wrapperDispatcher(coroutineContext)) { job -> in <lambda>()
234 withCtx(wrapperDispatcher(coroutineContext).minusKey(Job)) { in <lambda>()
265 withContext(wrapperDispatcher(coroutineContext) + job) { in <lambda>()
|
| D | WithContextCancellationStressTest.kt | 36 withContext(wrapperDispatcher(coroutineContext)) { in testConcurrentFailure()
79 private fun wrapperDispatcher(context: CoroutineContext): CoroutineContext { in wrapperDispatcher() method in kotlinx.coroutines.exceptions.WithContextCancellationStressTest
|
| D | StackTraceRecoveryChannelsTest.kt | 98 channel.sendWithContext(wrapperDispatcher(coroutineContext)) in <lambda>()
148 sendWithContext(wrapperDispatcher(coroutineContext)) in <lambda>()
|
| D | StackTraceRecoveryNestedScopesTest.kt | 32 …private suspend fun callWithContext(doYield: Boolean) = withContext(wrapperDispatcher(coroutineCon… in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/operators/ |
| D | BufferTest.kt | 136 flowOn(wrapperDispatcher()) in <lambda>()
142 flowOn(wrapperDispatcher()).buffer(5) in <lambda>()
148 buffer(6).flowOn(wrapperDispatcher()) in <lambda>()
166 flowOn(wrapperDispatcher()).buffer(3) in <lambda>()
168 .flowOn(wrapperDispatcher()).buffer(5) in <lambda>()
|
| D | FlowOnTest.kt | 270 }.flowOn(wrapperDispatcher()) in testCancellation()
287 .flowOn(wrapperDispatcher()) in <lambda>()
351 }.flowOn(wrapperDispatcher()).collect { in <lambda>()
|
| D | CatchTest.kt | 98 val d1 = wrapperDispatcher(coroutineContext) in <lambda>()
99 val d2 = wrapperDispatcher(coroutineContext) in <lambda>()
|
| D | FlowContextOptimizationsTest.kt | 12 val flowDispatcher = wrapperDispatcher(currentContext) in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | ThreadContextElementRestoreTest.kt | 38 withContext(wrapperDispatcher()) { in <lambda>()
157 withContext(wrapperDispatcher()) { in <lambda>()
164 withContext(wrapperDispatcher()) { in <lambda>()
|
| /external/kotlinx.coroutines/test-utils/common/src/ |
| D | TestBase.common.kt | 265 public fun wrapperDispatcher(context: CoroutineContext): CoroutineContext { in wrapperDispatcher() method
276 public suspend fun wrapperDispatcher(): CoroutineContext = wrapperDispatcher(coroutineContext) in wrapperDispatcher() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-debug/test/ |
| D | ToStringTest.kt | 128 withContext(wrapperDispatcher(coroutineContext)) { in CoroutineScope()
140 private fun wrapperDispatcher(context: CoroutineContext): CoroutineContext { in wrapperDispatcher() method
|
| D | ScopedBuildersTest.kt | 36 withContext(wrapperDispatcher(coroutineContext)) { in doWithContext()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/test/ |
| D | PublisherAsFlowTest.kt | 93 publisher.asFlow().flowOn(wrapperDispatcher()).buffer(1).collect { in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/channels/ |
| D | ChannelBuildersFlowTest.kt | 130 val scope = CoroutineScope(wrapperDispatcher()) in testProduceInAtomicity()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | PublisherAsFlowTest.kt | 94 publisher.asFlow().flowOn(wrapperDispatcher()).buffer(1).collect { in <lambda>()
|