Uses of Class
rx.Scheduler.Worker
Packages that use Scheduler.Worker
Package
Description
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
Scheduler implementations, value+time record classes and the standard factory class to
return standard RxJava schedulers or wrap any Executor-based (thread pool) instances.
Classes extending the Observable base reactive class and implementing
the Observer interface at the same time (aka hot Observables).
-
Uses of Scheduler.Worker in rx
Methods in rx that return Scheduler.WorkerModifier and TypeMethodDescriptionabstract Scheduler.Worker
Scheduler.createWorker()
Retrieves or creates a newScheduler.Worker
that represents serial execution of actions. -
Uses of Scheduler.Worker in rx.internal.operators
Fields in rx.internal.operators declared as Scheduler.WorkerModifier and TypeFieldDescription(package private) final Scheduler.Worker
OperatorBufferWithTime.ExactSubscriber.inner
(package private) final Scheduler.Worker
OperatorBufferWithTime.InexactSubscriber.inner
(package private) final Scheduler.Worker
OperatorRetryWithPredicate.SourceSubscriber.inner
(package private) final Scheduler.Worker
OperatorTimeoutBase.TimeoutSubscriber.inner
(package private) final Scheduler.Worker
OperatorObserveOn.ObserveOnSubscriber.recursiveScheduler
(package private) final Scheduler.Worker
OperatorWindowWithTime.ExactSubscriber.worker
(package private) final Scheduler.Worker
OperatorWindowWithTime.InexactSubscriber.worker
Constructors in rx.internal.operators with parameters of type Scheduler.WorkerModifierConstructorDescriptionExactSubscriber
(Subscriber<? super List<T>> child, Scheduler.Worker inner) ExactSubscriber
(Subscriber<? super Observable<T>> child, Scheduler.Worker worker) InexactSubscriber
(Subscriber<? super List<T>> child, Scheduler.Worker inner) InexactSubscriber
(Subscriber<? super Observable<T>> child, Scheduler.Worker worker) SourceSubscriber
(Subscriber<? super T> child, Func2<Integer, Throwable, Boolean> predicate, Scheduler.Worker inner, SerialSubscription serialSubscription, ProducerArbiter pa) (package private)
TimeoutSubscriber
(SerializedSubscriber<T> serializedSubscriber, OperatorTimeoutBase.TimeoutStub<T> timeoutStub, SerialSubscription serial, Observable<? extends T> other, Scheduler.Worker inner) -
Uses of Scheduler.Worker in rx.internal.schedulers
Subclasses of Scheduler.Worker in rx.internal.schedulersModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
Worker that schedules tasks on the executor indirectly through a trampoline mechanism.private class
class
(package private) static final class
Fields in rx.internal.schedulers declared as Scheduler.WorkerMethods in rx.internal.schedulers that return Scheduler.WorkerModifier and TypeMethodDescriptionCachedThreadScheduler.createWorker()
EventLoopsScheduler.createWorker()
ExecutorScheduler.createWorker()
ImmediateScheduler.createWorker()
NewThreadScheduler.createWorker()
SchedulerWhen.createWorker()
TrampolineScheduler.createWorker()
Methods in rx.internal.schedulers with parameters of type Scheduler.WorkerModifier and TypeMethodDescriptionprivate final void
SchedulerWhen.ScheduledAction.call
(Scheduler.Worker actualWorker) protected Subscription
SchedulerWhen.DelayedAction.callActual
(Scheduler.Worker actualWorker) protected Subscription
SchedulerWhen.ImmediateAction.callActual
(Scheduler.Worker actualWorker) protected abstract Subscription
SchedulerWhen.ScheduledAction.callActual
(Scheduler.Worker actualWorker) Constructors in rx.internal.schedulers with parameters of type Scheduler.WorkerModifierConstructorDescriptionSleepingAction
(Action0 underlying, Scheduler.Worker scheduler, long execTime) -
Uses of Scheduler.Worker in rx.schedulers
Subclasses of Scheduler.Worker in rx.schedulersFields in rx.schedulers declared as Scheduler.WorkerModifier and TypeFieldDescription(package private) final Scheduler.Worker
TestScheduler.TimedAction.scheduler
Methods in rx.schedulers that return Scheduler.WorkerModifier and TypeMethodDescriptionImmediateScheduler.createWorker()
Deprecated.NewThreadScheduler.createWorker()
Deprecated.TestScheduler.createWorker()
TrampolineScheduler.createWorker()
Deprecated.Constructors in rx.schedulers with parameters of type Scheduler.WorkerModifierConstructorDescription(package private)
TimedAction
(Scheduler.Worker scheduler, long time, Action0 action) -
Uses of Scheduler.Worker in rx.subjects
Fields in rx.subjects declared as Scheduler.Worker