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 newScheduler.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
-