Searched refs:scheduleDirect (Results 1 – 6 of 6) sorted by relevance
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| D | SchedulerTest.kt | 106 ensureSeparateThread(it::scheduleDirect, it::scheduleDirect) in <lambda>()
143 checkCancelling(it::scheduleDirect) in <lambda>()
166 scheduler.scheduleDirect { in <lambda>()
224 val disposable3 = it.scheduleDirect { in <lambda>()
233 val disposable4 = it.scheduleDirect { in <lambda>()
244 testRunnableWithNoDelay(scheduler::scheduleDirect) in <lambda>()
268 testRunnableWithDelay(scheduler::scheduleDirect, 300) in <lambda>()
280 testRunnableWithDelay(scheduler::scheduleDirect) in <lambda>()
303 testRunnableWithDelay(scheduler::scheduleDirect, -1) in <lambda>()
315 testRunnableImmediateDispose(scheduler::scheduleDirect) in <lambda>()
[all …]
|
| D | SchedulerStressTest.kt | 25 testRunnableDisposed(scheduler::scheduleDirect) in <lambda>()
64 testRunnableDisposedDuringDelay(scheduler::scheduleDirect) in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| D | SchedulerTest.kt | 106 ensureSeparateThread(it::scheduleDirect, it::scheduleDirect) in <lambda>()
143 checkCancelling(it::scheduleDirect) in <lambda>()
166 scheduler.scheduleDirect { in <lambda>()
224 val disposable3 = it.scheduleDirect { in <lambda>()
233 val disposable4 = it.scheduleDirect { in <lambda>()
244 testRunnableWithNoDelay(scheduler::scheduleDirect) in <lambda>()
268 testRunnableWithDelay(scheduler::scheduleDirect, 300) in <lambda>()
280 testRunnableWithDelay(scheduler::scheduleDirect) in <lambda>()
303 testRunnableWithDelay(scheduler::scheduleDirect, -1) in <lambda>()
315 testRunnableImmediateDispose(scheduler::scheduleDirect) in <lambda>()
[all …]
|
| D | SchedulerStressTest.kt | 25 testRunnableDisposed(scheduler::scheduleDirect) in <lambda>()
64 testRunnableDisposedDuringDelay(scheduler::scheduleDirect) in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/ |
| D | RxScheduler.kt | 58 override fun scheduleDirect(block: Runnable, delay: Long, unit: TimeUnit): Disposable = in scheduleDirect() method in kotlinx.coroutines.rx2.DispatcherScheduler
156 scheduler.scheduleDirect(block) in dispatch()
161 val disposable = scheduler.scheduleDirect({ in scheduleResumeAfterDelay()
169 val disposable = scheduler.scheduleDirect(block, timeMillis, TimeUnit.MILLISECONDS) in invokeOnTimeout()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/ |
| D | RxScheduler.kt | 58 override fun scheduleDirect(block: Runnable, delay: Long, unit: TimeUnit): Disposable = in scheduleDirect() method in kotlinx.coroutines.rx3.DispatcherScheduler
156 scheduler.scheduleDirect(block) in dispatch()
161 val disposable = scheduler.scheduleDirect({ in scheduleResumeAfterDelay()
169 val disposable = scheduler.scheduleDirect(block, timeMillis, TimeUnit.MILLISECONDS) in invokeOnTimeout()
|