| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/ |
| D | WithContextTest.kt | 34 withContext<Unit>(wrapperDispatcher(coroutineContext)) { in <lambda>()
141 withContext(job + wrapperDispatcher(coroutineContext)) { in <lambda>()
179 withContext<Unit>(wrapperDispatcher(coroutineContext)) { in <lambda>()
207 withContext<Unit>(wrapperDispatcher(coroutineContext)) { in <lambda>()
236 withContext(wrapperDispatcher(coroutineContext)) { in <lambda>()
264 withContext(wrapperDispatcher(coroutineContext)) { in <lambda>()
300 withContext(wrapperDispatcher(coroutineContext)) { in <lambda>()
315 withContext(wrapperDispatcher(coroutineContext)) { in <lambda>()
346 withContext(wrapperDispatcher(coroutineContext)) { in <lambda>()
356 withContext(wrapperDispatcher()) { in <lambda>()
|
| D | TestBase.common.kt | 71 public fun wrapperDispatcher(context: CoroutineContext): CoroutineContext { in wrapperDispatcher() method
81 public suspend fun wrapperDispatcher(): CoroutineContext = wrapperDispatcher(coroutineContext) in wrapperDispatcher() method
|
| D | ImmediateYieldTest.kt | 39 launch(wrapperDispatcher(Dispatchers.Unconfined)) { in isDispatchNeeded()
50 withContext(wrapperDispatcher(Dispatchers.Unconfined)) { in <lambda>()
|
| D | UndispatchedResultTest.kt | 14 invokeTest { block -> withContext(wrapperDispatcher(coroutineContext), block) } in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/exceptions/ |
| D | StackTraceRecoveryResumeModeTest.kt | 40 testResumeModeFastPath(wrapperDispatcher()) in <lambda>()
45 val dispatcher = wrapperDispatcher() in <lambda>()
53 withContext(wrapperDispatcher()) { in <lambda>()
101 testResumeModeSuspending(wrapperDispatcher()) in <lambda>()
106 val dispatcher = wrapperDispatcher() in <lambda>()
114 withContext(wrapperDispatcher()) { in <lambda>()
|
| D | StackTraceRecoveryCustomExceptionsTest.kt | 33 withContext(wrapperDispatcher(coroutineContext)) { in testStackTraceNotRecovered()
46 withContext(wrapperDispatcher(coroutineContext)) { in <lambda>()
63 withContext(wrapperDispatcher(coroutineContext)) { in <lambda>()
|
| D | WithContextExceptionHandlingTest.kt | 199 private fun wrapperDispatcher(context: CoroutineContext): CoroutineContext { in <lambda>() method in kotlinx.coroutines.exceptions.WithContextExceptionHandlingTest
216 withCtx(wrapperDispatcher(coroutineContext)) { job -> in <lambda>()
237 withCtx(wrapperDispatcher(coroutineContext).minusKey(Job)) { in <lambda>()
268 withContext(wrapperDispatcher(coroutineContext) + job) { in <lambda>()
|
| D | WithContextCancellationStressTest.kt | 37 withContext(wrapperDispatcher(coroutineContext)) { in testConcurrentFailure()
83 private fun wrapperDispatcher(context: CoroutineContext): CoroutineContext { in wrapperDispatcher() method
|
| D | StackTraceRecoveryChannelsTest.kt | 109 channel.sendWithContext(wrapperDispatcher(coroutineContext)) in <lambda>()
178 sendWithContext(wrapperDispatcher(coroutineContext)) in <lambda>()
|
| D | StackTraceRecoveryNestedScopesTest.kt | 31 …private suspend fun callWithContext(doYield: Boolean) = withContext(wrapperDispatcher(coroutineCon… in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/operators/ |
| D | BufferTest.kt | 139 flowOn(wrapperDispatcher()) in <lambda>()
145 flowOn(wrapperDispatcher()).buffer(5) in <lambda>()
151 buffer(6).flowOn(wrapperDispatcher()) in <lambda>()
169 flowOn(wrapperDispatcher()).buffer(3) in <lambda>()
171 .flowOn(wrapperDispatcher()).buffer(5) in <lambda>()
|
| D | CatchTest.kt | 101 val d1 = wrapperDispatcher(coroutineContext) in <lambda>()
102 val d2 = wrapperDispatcher(coroutineContext) in <lambda>()
|
| D | FlowOnTest.kt | 272 }.flowOn(wrapperDispatcher()) in testCancellation()
289 .flowOn(wrapperDispatcher()) in <lambda>()
353 }.flowOn(wrapperDispatcher()).collect { in <lambda>()
|
| D | FlowContextOptimizationsTest.kt | 15 val flowDispatcher = wrapperDispatcher(currentContext) in <lambda>()
|
| /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 | 42 withContext(wrapperDispatcher(coroutineContext)) { in doWithContext()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/test/ |
| D | PublisherAsFlowTest.kt | 95 publisher.asFlow().flowOn(wrapperDispatcher()).buffer(1).collect { in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | PublisherAsFlowTest.kt | 96 publisher.asFlow().flowOn(wrapperDispatcher()).buffer(1).collect { in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/channels/ |
| D | ChannelBuildersFlowTest.kt | 272 val scope = CoroutineScope(wrapperDispatcher()) in testProduceInAtomicity()
|