Package rx.internal.schedulers
-
Interface Summary Interface Description SchedulerLifecycle Represents the capability of a Scheduler to be start or shut down its maintained threads. -
Class Summary Class Description CachedThreadScheduler CachedThreadScheduler.CachedWorkerPool CachedThreadScheduler.EventLoopWorker CachedThreadScheduler.ThreadWorker EventLoopsScheduler EventLoopsScheduler.EventLoopWorker EventLoopsScheduler.FixedSchedulerPool EventLoopsScheduler.PoolWorker ExecutorScheduler Scheduler that wraps an Executor instance and establishes the Scheduler contract upon it.ExecutorScheduler.ExecutorSchedulerWorker Worker that schedules tasks on the executor indirectly through a trampoline mechanism.GenericScheduledExecutorService A defaultScheduledExecutorService
that can be used for scheduling actions when aScheduler
implementation doesn't have that ability.ImmediateScheduler Executes work immediately on the current thread.NewThreadScheduler Schedules work on a new thread.NewThreadWorker ScheduledAction ARunnable
that executes anAction0
and can be cancelled.ScheduledAction.Remover Remove a child subscription from a composite when unsubscribing.ScheduledAction.Remover2 Remove a child subscription from a composite when unsubscribing.SchedulerWhen Allows the use of operators for controlling the timing around when actions scheduled on workers are actually done.SchedulerWhen.DelayedAction SchedulerWhen.ImmediateAction SchedulerWhen.ScheduledAction SleepingAction TrampolineScheduler Schedules work on the current thread but does not execute immediately.TrampolineScheduler.InnerCurrentThreadScheduler TrampolineScheduler.TimedAction -
Enum Summary Enum Description GenericScheduledExecutorServiceFactory Utility class to create the individual ScheduledExecutorService instances for the GenericScheduledExecutorService class.