Uses of Class
rx.Scheduler.Worker

Packages that use Scheduler.Worker

Package	Description
rx	Base reactive classes: Observable, Single and Completable; base reactive consumers; other common base interfaces.
rx.internal.operators	Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner.
rx.internal.schedulers
rx.schedulers	Scheduler implementations, value+time record classes and the standard factory class to return standard RxJava schedulers or wrap any Executor-based (thread pool) instances.
rx.subjects	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.Worker

Modifier and Type	Method	Description
abstract Scheduler.Worker	Scheduler.createWorker()	Retrieves or creates a new Scheduler.Worker that represents serial execution of actions.

Uses of Scheduler.Worker in rx.internal.operators

Fields in rx.internal.operators declared as Scheduler.Worker

Modifier and Type	Field	Description
(package private) Scheduler.Worker	OperatorBufferWithTime.ExactSubscriber.inner
(package private) Scheduler.Worker	OperatorBufferWithTime.InexactSubscriber.inner
(package private) Scheduler.Worker	OperatorRetryWithPredicate.SourceSubscriber.inner
(package private) Scheduler.Worker	OperatorTimeoutBase.TimeoutSubscriber.inner
(package private) Scheduler.Worker	OperatorObserveOn.ObserveOnSubscriber.recursiveScheduler
(package private) Scheduler.Worker	OperatorWindowWithTime.ExactSubscriber.worker
(package private) Scheduler.Worker	OperatorWindowWithTime.InexactSubscriber.worker

Constructors in rx.internal.operators with parameters of type Scheduler.Worker

Constructor	Description
ExactSubscriber(Subscriber<? super java.util.List<T>> child, Scheduler.Worker inner)
ExactSubscriber(Subscriber<? super Observable<T>> child, Scheduler.Worker worker)
InexactSubscriber(Subscriber<? super java.util.List<T>> child, Scheduler.Worker inner)
InexactSubscriber(Subscriber<? super Observable<T>> child, Scheduler.Worker worker)
SourceSubscriber(Subscriber<? super T> child, Func2<java.lang.Integer,java.lang.Throwable,java.lang.Boolean> predicate, Scheduler.Worker inner, SerialSubscription serialSubscription, ProducerArbiter pa)
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.schedulers

Modifier and Type	Class	Description
(package private) static class	CachedThreadScheduler.EventLoopWorker
(package private) static class	CachedThreadScheduler.ThreadWorker
(package private) static class	EventLoopsScheduler.EventLoopWorker
(package private) static class	EventLoopsScheduler.PoolWorker
(package private) static class	ExecutorScheduler.ExecutorSchedulerWorker	Worker that schedules tasks on the executor indirectly through a trampoline mechanism.
private class	ImmediateScheduler.InnerImmediateScheduler
class	NewThreadWorker
(package private) static class	TrampolineScheduler.InnerCurrentThreadScheduler

Fields in rx.internal.schedulers declared as Scheduler.Worker

Modifier and Type	Field	Description
private Scheduler.Worker	SleepingAction.innerScheduler

Methods in rx.internal.schedulers that return Scheduler.Worker

Modifier and Type	Method	Description
Scheduler.Worker	CachedThreadScheduler.createWorker()
Scheduler.Worker	EventLoopsScheduler.createWorker()
Scheduler.Worker	ExecutorScheduler.createWorker()
Scheduler.Worker	ImmediateScheduler.createWorker()
Scheduler.Worker	NewThreadScheduler.createWorker()
Scheduler.Worker	SchedulerWhen.createWorker()
Scheduler.Worker	TrampolineScheduler.createWorker()

Methods in rx.internal.schedulers with parameters of type Scheduler.Worker

Modifier and Type	Method	Description
private 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.Worker

Constructor	Description
SleepingAction(Action0 underlying, Scheduler.Worker scheduler, long execTime)

Uses of Scheduler.Worker in rx.schedulers

Subclasses of Scheduler.Worker in rx.schedulers

Modifier and Type	Class	Description
(package private) class	TestScheduler.InnerTestScheduler

Fields in rx.schedulers declared as Scheduler.Worker

Modifier and Type	Field	Description
(package private) Scheduler.Worker	TestScheduler.TimedAction.scheduler

Methods in rx.schedulers that return Scheduler.Worker

Modifier and Type	Method	Description
Scheduler.Worker	ImmediateScheduler.createWorker()	Deprecated.
Scheduler.Worker	NewThreadScheduler.createWorker()	Deprecated.
Scheduler.Worker	TestScheduler.createWorker()
Scheduler.Worker	TrampolineScheduler.createWorker()	Deprecated.

Constructors in rx.schedulers with parameters of type Scheduler.Worker

Constructor	Description
TimedAction(Scheduler.Worker scheduler, long time, Action0 action)

Uses of Scheduler.Worker in rx.subjects

Fields in rx.subjects declared as Scheduler.Worker

Modifier and Type	Field	Description
private Scheduler.Worker	TestSubject.innerScheduler