| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | RejectedExecutionTest.kt | 28 val job = launch(executor.asCoroutineDispatcher()) { in <lambda>()
39 val job = launch(executor.asCoroutineDispatcher(), start = CoroutineStart.ATOMIC) { in <lambda>()
53 withContext(executor.asCoroutineDispatcher()) { in <lambda>()
66 withContext(executor.asCoroutineDispatcher()) { in <lambda>()
97 withContext(executor.asCoroutineDispatcher()) { in <lambda>()
119 withContext(executor.asCoroutineDispatcher()) { in <lambda>()
|
| D | ExecutorsTest.kt | 41 runBlocking(executor.asCoroutineDispatcher()) { in <lambda>()
52 val dispatcher: CoroutineDispatcher = executor.asCoroutineDispatcher() in <lambda>()
77 assertSame(dispatcher, executor.asCoroutineDispatcher()) in <lambda>()
102 val dispatcher = executorService.asCoroutineDispatcher() in <lambda>()
|
| D | WithTimeoutOrNullThreadDispatchTest.kt | 26 executor!!.asCoroutineDispatcher() in testCancellationDispatchScheduled()
34 executor!!.asCoroutineDispatcher() in testCancellationDispatchNonScheduled()
|
| D | WithTimeoutThreadDispatchTest.kt | 26 executor!!.asCoroutineDispatcher() in testCancellationDispatchScheduled()
34 executor!!.asCoroutineDispatcher() in testCancellationDispatchNonScheduled()
|
| D | FailingCoroutinesMachineryTest.kt | 103 …her("Executors.newFixedThreadPool(1)") { Executors.newFixedThreadPool(1).asCoroutineDispatcher() }, in <lambda>()
104 …cutors.newScheduledThreadPool(1)") { Executors.newScheduledThreadPool(1).asCoroutineDispatcher() }, in <lambda>()
|
| /external/kotlinx.coroutines/ui/kotlinx-coroutines-android/test/ |
| D | HandlerDispatcherTest.kt | 49 val main = Looper.getMainLooper().asHandler(async = true).asCoroutineDispatcher() in <lambda>()
68 val main = Looper.getMainLooper().asHandler(async = true).asCoroutineDispatcher() in <lambda>()
87 val main = Looper.getMainLooper().asHandler(async = true).asCoroutineDispatcher() in <lambda>()
106 val main = Looper.getMainLooper().asHandler(async = false).asCoroutineDispatcher() in <lambda>()
124 val main = Looper.getMainLooper().asHandler(async = true).asCoroutineDispatcher("testName") in testToString()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/src/ |
| D | Window.kt | 13 public fun Window.asCoroutineDispatcher(): CoroutineDispatcher = in <lambda>() method
36 private val dispatcher = window.asCoroutineDispatcher()
|
| D | CoroutineContext.kt | 27 window.asCoroutineDispatcher() in createDefaultDispatcher()
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/scheduler/ |
| D | DispatchersContextSwitchBenchmark.kt | 27 private val fjp = ForkJoinPool.commonPool().asCoroutineDispatcher()
28 private val ftp = Executors.newFixedThreadPool(CORES_COUNT - 1).asCoroutineDispatcher()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/ |
| D | README.md | 31 | [Scheduler.asCoroutineDispatcher][reactor.core.scheduler.Scheduler.asCoroutineDispatcher] | Conve…
49 [reactor.core.scheduler.Scheduler.asCoroutineDispatcher]: https://kotlin.github.io/kotlinx.coroutin…
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | Executors.kt | 49 public fun ExecutorService.asCoroutineDispatcher(): ExecutorCoroutineDispatcher = in close() method
62 public fun Executor.asCoroutineDispatcher(): CoroutineDispatcher = in close() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/test/ |
| D | SchedulerTest.kt | 23 withContext(Schedulers.single().asCoroutineDispatcher()) { in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| D | SchedulerTest.kt | 23 withContext(Schedulers.io().asCoroutineDispatcher()) { in <lambda>()
|
| D | LeakedExceptionTest.kt | 100 val dispatcher = pool.asCoroutineDispatcher() in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| D | SchedulerTest.kt | 23 withContext(Schedulers.io().asCoroutineDispatcher()) { in <lambda>()
|
| D | LeakedExceptionTest.kt | 100 val dispatcher = pool.asCoroutineDispatcher() in <lambda>()
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/ |
| D | ParametrizedDispatcherBase.kt | 31 dispatcher == "fjp" -> ForkJoinPool.commonPool().asCoroutineDispatcher() in setup()
|
| D | SemaphoreBenchmark.kt | 86 FORK_JOIN({ parallelism -> ForkJoinPool(parallelism).asCoroutineDispatcher() }), in parallelism()
|
| D | ChannelProducerConsumerBenchmark.kt | 131 FORK_JOIN({ parallelism -> ForkJoinPool(parallelism).asCoroutineDispatcher() }) in parallelism()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/ |
| D | RxScheduler.kt | 16 public fun Scheduler.asCoroutineDispatcher(): SchedulerCoroutineDispatcher = SchedulerCoroutineDisp… in asCoroutineDispatcher() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/ |
| D | RxScheduler.kt | 16 public fun Scheduler.asCoroutineDispatcher(): SchedulerCoroutineDispatcher = SchedulerCoroutineDisp… in asCoroutineDispatcher() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/src/ |
| D | Scheduler.kt | 16 public fun Scheduler.asCoroutineDispatcher(): SchedulerCoroutineDispatcher = SchedulerCoroutineDisp… in asCoroutineDispatcher() method
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/scheduler/actors/ |
| D | PingPongWithBlockingContext.kt | 55 runPingPongs(ForkJoinPool.commonPool().asCoroutineDispatcher(), threadPool) in commonPoolWithContextPingPong()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/ |
| D | README.md | 48 | [Scheduler.asCoroutineDispatcher][io.reactivex.rxjava3.core.Scheduler.asCoroutineDispatcher] | Co…
79 [io.reactivex.rxjava3.core.Scheduler.asCoroutineDispatcher]: https://kotlin.github.io/kotlinx.corou…
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/ |
| D | README.md | 51 | [Scheduler.asCoroutineDispatcher][io.reactivex.Scheduler.asCoroutineDispatcher] | Converts schedu…
86 [io.reactivex.Scheduler.asCoroutineDispatcher]: https://kotlin.github.io/kotlinx.coroutines/kotlinx…
|