Uses of Package
io.reactivex.rxjava3.internal.schedulers
-
Packages that use io.reactivex.rxjava3.internal.schedulers Package Description io.reactivex.rxjava3.internal.operators.parallel io.reactivex.rxjava3.internal.schedulers -
Classes in io.reactivex.rxjava3.internal.schedulers used by io.reactivex.rxjava3.internal.operators.parallel Class Description SchedulerMultiWorkerSupport.WorkerCallback The callback interface for theSchedulerMultiWorkerSupport.createWorkers(int, WorkerCallback)
method. -
Classes in io.reactivex.rxjava3.internal.schedulers used by io.reactivex.rxjava3.internal.schedulers Class Description AbstractDirectTask Base functionality for direct tasks that manage a runnable and cancellation/completion.ComputationScheduler.FixedSchedulerPool ComputationScheduler.PoolWorker ExecutorScheduler.DelayedRunnable IoScheduler.CachedWorkerPool IoScheduler.ThreadWorker NewThreadWorker Base class that manages a single-threaded ScheduledExecutorService as a worker but doesn't perform task-tracking operations.NonBlockingThread Marker interface to indicate blocking is not recommended while running on a Scheduler with a thread type implementing it.RxThreadFactory A ThreadFactory that counts how many threads have been created and given a prefix, sets the created Thread's name toprefix-count
.ScheduledRunnable SchedulerMultiWorkerSupport Allows retrieving multiple workers from the implementingScheduler
in a way that when asking for at most the parallelism level of the Scheduler, thoseScheduler.Worker
instances will be running with different backing threads.SchedulerMultiWorkerSupport.WorkerCallback The callback interface for theSchedulerMultiWorkerSupport.createWorkers(int, WorkerCallback)
method.SchedulerWhen.ScheduledAction TrampolineScheduler Schedules work on the current thread but does not execute immediately.TrampolineScheduler.TimedRunnable TrampolineScheduler.TrampolineWorker