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) 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.Worker

Modifier	Constructor	Description
	ExactSubscriber(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.schedulers

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

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

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

Modifier	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) final class	TestScheduler.InnerTestScheduler

Fields in rx.schedulers declared as Scheduler.Worker

Modifier and Type	Field	Description
(package private) final 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

Modifier	Constructor	Description
(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

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