Home
last modified time | relevance | path

Searched refs:createWorker (Results 1 – 7 of 7) sorted by relevance

/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/
DSchedulerTest.kt49 val worker = scheduler.createWorker() in <lambda>()
114 val worker = it.createWorker() in <lambda>()
151 val worker = it.createWorker() in <lambda>()
190 val worker = scheduler.createWorker() in <lambda>()
201 val worker = it.createWorker() in <lambda>()
250 testRunnableWithNoDelay(scheduler.createWorker()::schedule) in <lambda>()
274 testRunnableWithDelay(scheduler.createWorker()::schedule, 300) in <lambda>()
286 testRunnableWithDelay(scheduler.createWorker()::schedule) in <lambda>()
309 testRunnableWithDelay(scheduler.createWorker()::schedule, -1) in <lambda>()
321 testRunnableImmediateDispose(scheduler.createWorker()::schedule) in <lambda>()
[all …]
DSchedulerStressTest.kt32 val worker = scheduler.createWorker() in <lambda>()
71 val worker = scheduler.createWorker() in <lambda>()
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/
DSchedulerTest.kt49 val worker = scheduler.createWorker() in <lambda>()
114 val worker = it.createWorker() in <lambda>()
151 val worker = it.createWorker() in <lambda>()
190 val worker = scheduler.createWorker() in <lambda>()
201 val worker = it.createWorker() in <lambda>()
250 testRunnableWithNoDelay(scheduler.createWorker()::schedule) in <lambda>()
274 testRunnableWithDelay(scheduler.createWorker()::schedule, 300) in <lambda>()
286 testRunnableWithDelay(scheduler.createWorker()::schedule) in <lambda>()
309 testRunnableWithDelay(scheduler.createWorker()::schedule, -1) in <lambda>()
321 testRunnableImmediateDispose(scheduler.createWorker()::schedule) in <lambda>()
[all …]
DSchedulerStressTest.kt32 val worker = scheduler.createWorker() in <lambda>()
71 val worker = scheduler.createWorker() in <lambda>()
/external/libtextclassifier/java/tests/instrumentation/src/com/android/textclassifier/downloader/
DModelDownloadWorkerTest.java191 ModelDownloadWorker worker = createWorker(RUN_ATTEMPT_COUNT); in downloadSucceed()
209 ModelDownloadWorker worker = createWorker(RUN_ATTEMPT_COUNT); in downloadSucceed_modelAlreadyExists()
226 ModelDownloadWorker worker = createWorker(RUN_ATTEMPT_COUNT); in downloadSucceed_manifestAlreadyExists()
258 ModelDownloadWorker worker = createWorker(RUN_ATTEMPT_COUNT); in downloadSucceed_downloadMultipleModels()
302 ModelDownloadWorker worker = createWorker(RUN_ATTEMPT_COUNT); in downloadSucceed_shareSingleModelDownloadForMultipleManifest()
344 ModelDownloadWorker worker = createWorker(RUN_ATTEMPT_COUNT); in downloadSucceed_shareManifest()
375 ModelDownloadWorker worker = createWorker(RUN_ATTEMPT_COUNT); in downloadFailed_failedToDownloadManifest()
391 ModelDownloadWorker worker = createWorker(RUN_ATTEMPT_COUNT); in downloadFailed_failedToDownloadModel()
402 ModelDownloadWorker worker = createWorker(RUN_ATTEMPT_COUNT); in downloadFailed_modelDownloadManagerDisabled()
412 ModelDownloadWorker worker = createWorker(WORKER_MAX_RUN_ATTEMPT_COUNT); in downloadFailed_reachWorkerMaxRunAttempts()
[all …]
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/
DRxScheduler.kt63 …override fun createWorker(): Worker = DispatcherWorker(workerCounter.getAndIncrement(), dispatcher… in createWorker() method in kotlinx.coroutines.rx2.DispatcherScheduler
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/
DRxScheduler.kt63 …override fun createWorker(): Worker = DispatcherWorker(workerCounter.getAndIncrement(), dispatcher… in createWorker() method in kotlinx.coroutines.rx3.DispatcherScheduler