Searched refs:SchedulerCoroutineDispatcher (Results 1 – 15 of 15) sorted by relevance
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/ |
| D | RxScheduler.kt | 24 SchedulerCoroutineDispatcher(this)
29 public fun Scheduler.asCoroutineDispatcher0(): SchedulerCoroutineDispatcher = in asCoroutineDispatcher0()
30 SchedulerCoroutineDispatcher(this) in asCoroutineDispatcher0()
36 if (this is SchedulerCoroutineDispatcher) { in asCoroutineDispatcher0()
148 public class SchedulerCoroutineDispatcher( class
177 …override fun equals(other: Any?): Boolean = other is SchedulerCoroutineDispatcher && other.schedul…
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/src/ |
| D | Scheduler.kt | 16 public fun Scheduler.asCoroutineDispatcher(): SchedulerCoroutineDispatcher = SchedulerCoroutineDisp… in asCoroutineDispatcher()
22 public class SchedulerCoroutineDispatcher( in asCoroutineDispatcher() class
48 …override fun equals(other: Any?): Boolean = other is SchedulerCoroutineDispatcher && other.schedul… in asCoroutineDispatcher()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/ |
| D | RxScheduler.kt | 25 SchedulerCoroutineDispatcher(this)
30 public fun Scheduler.asCoroutineDispatcher0(): SchedulerCoroutineDispatcher = in asCoroutineDispatcher0()
31 SchedulerCoroutineDispatcher(this) in asCoroutineDispatcher0()
37 if (this is SchedulerCoroutineDispatcher) { in asCoroutineDispatcher0()
149 public class SchedulerCoroutineDispatcher( class
178 …override fun equals(other: Any?): Boolean = other is SchedulerCoroutineDispatcher && other.schedul…
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/ |
| D | CoroutineSchedulerTest.kt | 109 SchedulerCoroutineDispatcher(-1, 4) in <lambda>()
114 SchedulerCoroutineDispatcher(1, -4) in <lambda>()
119 SchedulerCoroutineDispatcher(4, 1) in <lambda>()
124 val dispatcher = SchedulerCoroutineDispatcher(1, 1) in <lambda>()
134 SchedulerCoroutineDispatcher(1, 1).use { in <lambda>()
|
| D | SharingWorkerClassTest.kt | 16 val dispatcher = SchedulerCoroutineDispatcher(1, schedulerName = "first") in <lambda>()
17 val dispatcher2 = SchedulerCoroutineDispatcher(1, schedulerName = "second") in <lambda>()
42 SchedulerCoroutineDispatcher(1).close() in <lambda>()
|
| D | SchedulerTestBase.kt | 63 private var _dispatcher: SchedulerCoroutineDispatcher? = null
67 _dispatcher = SchedulerCoroutineDispatcher(
101 internal fun SchedulerCoroutineDispatcher.blocking(parallelism: Int = 16): CoroutineDispatcher { in blocking()
|
| D | CoroutineSchedulerCloseStressTest.kt | 30 private lateinit var closeableDispatcher: SchedulerCoroutineDispatcher
46 closeableDispatcher = SchedulerCoroutineDispatcher(N_THREADS) in <lambda>()
|
| D | CoroutineSchedulerStressTest.kt | 18 private var dispatcher: SchedulerCoroutineDispatcher = SchedulerCoroutineDispatcher()
|
| D | BlockingCoroutineDispatcherTerminationStressTest.kt | 13 private val baseDispatcher = SchedulerCoroutineDispatcher(
|
| D | BlockingCoroutineDispatcherWorkSignallingStressTest.kt | 21 val dispatcher = SchedulerCoroutineDispatcher(CORES_COUNT) in <lambda>()
|
| D | CoroutineDispatcherTest.kt | 137 … val dispatcher = SchedulerCoroutineDispatcher(1, 1, IDLE_WORKER_KEEP_ALIVE_NS, "SomeTestName") in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/scheduling/ |
| D | Dispatcher.kt | 13 internal object DefaultScheduler : SchedulerCoroutineDispatcher(
81 internal open class SchedulerCoroutineDispatcher( in toString() class
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/api/ |
| D | kotlinx-coroutines-reactor.api | 55 public final class kotlinx/coroutines/reactor/SchedulerCoroutineDispatcher : kotlinx/coroutines/Cor…
68 …tcher (Lreactor/core/scheduler/Scheduler;)Lkotlinx/coroutines/reactor/SchedulerCoroutineDispatcher;
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/api/ |
| D | kotlinx-coroutines-rx3.api | 62 …atcher (Lio/reactivex/rxjava3/core/Scheduler;)Lkotlinx/coroutines/rx3/SchedulerCoroutineDispatcher;
71 public final class kotlinx/coroutines/rx3/SchedulerCoroutineDispatcher : kotlinx/coroutines/Corouti…
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/api/ |
| D | kotlinx-coroutines-rx2.api | 73 …CoroutineDispatcher (Lio/reactivex/Scheduler;)Lkotlinx/coroutines/rx2/SchedulerCoroutineDispatcher;
84 public final class kotlinx/coroutines/rx2/SchedulerCoroutineDispatcher : kotlinx/coroutines/Corouti…
|