Uses of Class
io.reactivex.rxjava3.core.Scheduler.Worker
Packages that use Scheduler.Worker
Package
Description
Base reactive classes:
Flowable
, Observable
,
Single
, Maybe
and
Completable
; base reactive consumers;
other common base interfaces.Contains notably the factory class of
Schedulers
providing methods for
retrieving the standard scheduler instances, the TestScheduler
for testing flows
with scheduling in a controlled manner and the class Timed
that can hold
a value and a timestamp associated with it.-
Uses of Scheduler.Worker in io.reactivex.rxjava3.core
Fields in io.reactivex.rxjava3.core declared as Scheduler.WorkerModifier and TypeFieldDescription(package private) final @NonNull Scheduler.Worker
Scheduler.DisposeTask.w
(package private) final @NonNull Scheduler.Worker
Scheduler.PeriodicDirectTask.worker
Methods in io.reactivex.rxjava3.core that return Scheduler.WorkerModifier and TypeMethodDescriptionabstract @NonNull Scheduler.Worker
Scheduler.createWorker()
Retrieves or creates a newScheduler.Worker
that represents sequential execution of actions.Constructors in io.reactivex.rxjava3.core with parameters of type Scheduler.WorkerModifierConstructorDescription(package private)
DisposeTask
(@NonNull Runnable decoratedRun, @NonNull Scheduler.Worker w) (package private)
PeriodicDirectTask
(@NonNull Runnable run, @NonNull Scheduler.Worker worker) -
Uses of Scheduler.Worker in io.reactivex.rxjava3.internal.operators.flowable
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as Scheduler.WorkerModifier and TypeFieldDescription(package private) final Scheduler.Worker
FlowableBufferTimed.BufferExactBoundedSubscriber.w
(package private) final Scheduler.Worker
FlowableBufferTimed.BufferSkipBoundedSubscriber.w
(package private) final Scheduler.Worker
FlowableDelay.DelaySubscriber.w
(package private) final Scheduler.Worker
FlowableConcatMapScheduler.BaseConcatMapSubscriber.worker
(package private) final Scheduler.Worker
FlowableDebounceTimed.DebounceTimedSubscriber.worker
(package private) final Scheduler.Worker
FlowableObserveOn.BaseObserveOnSubscriber.worker
(package private) final Scheduler.Worker
FlowableSubscribeOn.SubscribeOnSubscriber.worker
(package private) final Scheduler.Worker
FlowableThrottleFirstTimed.DebounceTimedSubscriber.worker
(package private) final Scheduler.Worker
FlowableThrottleLatest.ThrottleLatestSubscriber.worker
(package private) final Scheduler.Worker
FlowableTimeoutTimed.TimeoutFallbackSubscriber.worker
(package private) final Scheduler.Worker
FlowableTimeoutTimed.TimeoutSubscriber.worker
(package private) final Scheduler.Worker
FlowableWindowTimed.WindowExactBoundedSubscriber.worker
(package private) final Scheduler.Worker
FlowableWindowTimed.WindowSkipSubscriber.worker
Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type Scheduler.WorkerModifierConstructorDescription(package private)
BaseConcatMapSubscriber
(Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch, Scheduler.Worker worker) (package private)
BaseObserveOnSubscriber
(Scheduler.Worker worker, boolean delayError, int prefetch) (package private)
BufferExactBoundedSubscriber
(org.reactivestreams.Subscriber<? super U> actual, Supplier<U> bufferSupplier, long timespan, TimeUnit unit, int maxSize, boolean restartOnMaxSize, Scheduler.Worker w) (package private)
BufferSkipBoundedSubscriber
(org.reactivestreams.Subscriber<? super U> actual, Supplier<U> bufferSupplier, long timespan, long timeskip, TimeUnit unit, Scheduler.Worker w) (package private)
ConcatMapDelayed
(org.reactivestreams.Subscriber<? super R> actual, Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch, boolean veryEnd, Scheduler.Worker worker) (package private)
ConcatMapImmediate
(org.reactivestreams.Subscriber<? super R> actual, Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch, Scheduler.Worker worker) (package private)
DebounceTimedSubscriber
(org.reactivestreams.Subscriber<? super T> actual, long timeout, TimeUnit unit, Scheduler.Worker worker, Consumer<? super T> onDropped) (package private)
DebounceTimedSubscriber
(org.reactivestreams.Subscriber<? super T> actual, long timeout, TimeUnit unit, Scheduler.Worker worker, Consumer<? super T> onDropped) (package private)
DelaySubscriber
(org.reactivestreams.Subscriber<? super T> actual, long delay, TimeUnit unit, Scheduler.Worker w, boolean delayError) (package private)
ObserveOnConditionalSubscriber
(ConditionalSubscriber<? super T> actual, Scheduler.Worker worker, boolean delayError, int prefetch) (package private)
ObserveOnSubscriber
(org.reactivestreams.Subscriber<? super T> actual, Scheduler.Worker worker, boolean delayError, int prefetch) (package private)
SubscribeOnSubscriber
(org.reactivestreams.Subscriber<? super T> actual, Scheduler.Worker worker, org.reactivestreams.Publisher<T> source, boolean requestOn) (package private)
ThrottleLatestSubscriber
(org.reactivestreams.Subscriber<? super T> downstream, long timeout, TimeUnit unit, Scheduler.Worker worker, boolean emitLast, Consumer<? super T> onDropped) (package private)
TimeoutFallbackSubscriber
(org.reactivestreams.Subscriber<? super T> actual, long timeout, TimeUnit unit, Scheduler.Worker worker, org.reactivestreams.Publisher<? extends T> fallback) (package private)
TimeoutSubscriber
(org.reactivestreams.Subscriber<? super T> actual, long timeout, TimeUnit unit, Scheduler.Worker worker) (package private)
WindowSkipSubscriber
(org.reactivestreams.Subscriber<? super Flowable<T>> actual, long timespan, long timeskip, TimeUnit unit, Scheduler.Worker worker, int bufferSize) -
Uses of Scheduler.Worker in io.reactivex.rxjava3.internal.operators.observable
Fields in io.reactivex.rxjava3.internal.operators.observable declared as Scheduler.WorkerModifier and TypeFieldDescription(package private) final Scheduler.Worker
ObservableBufferTimed.BufferExactBoundedObserver.w
(package private) final Scheduler.Worker
ObservableBufferTimed.BufferSkipBoundedObserver.w
(package private) final Scheduler.Worker
ObservableDelay.DelayObserver.w
(package private) final Scheduler.Worker
ObservableConcatMapScheduler.ConcatMapDelayErrorObserver.worker
(package private) final Scheduler.Worker
ObservableConcatMapScheduler.ConcatMapObserver.worker
(package private) final Scheduler.Worker
ObservableDebounceTimed.DebounceTimedObserver.worker
(package private) final Scheduler.Worker
ObservableObserveOn.ObserveOnObserver.worker
(package private) final Scheduler.Worker
ObservableThrottleFirstTimed.DebounceTimedObserver.worker
(package private) final Scheduler.Worker
ObservableThrottleLatest.ThrottleLatestObserver.worker
(package private) final Scheduler.Worker
ObservableTimeoutTimed.TimeoutFallbackObserver.worker
(package private) final Scheduler.Worker
ObservableTimeoutTimed.TimeoutObserver.worker
(package private) final Scheduler.Worker
ObservableWindowTimed.WindowExactBoundedObserver.worker
(package private) final Scheduler.Worker
ObservableWindowTimed.WindowSkipObserver.worker
Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type Scheduler.WorkerModifierConstructorDescription(package private)
BufferExactBoundedObserver
(Observer<? super U> actual, Supplier<U> bufferSupplier, long timespan, TimeUnit unit, int maxSize, boolean restartOnMaxSize, Scheduler.Worker w) (package private)
BufferSkipBoundedObserver
(Observer<? super U> actual, Supplier<U> bufferSupplier, long timespan, long timeskip, TimeUnit unit, Scheduler.Worker w) (package private)
ConcatMapDelayErrorObserver
(Observer<? super R> actual, Function<? super T, ? extends ObservableSource<? extends R>> mapper, int bufferSize, boolean tillTheEnd, Scheduler.Worker worker) (package private)
ConcatMapObserver
(Observer<? super U> actual, Function<? super T, ? extends ObservableSource<? extends U>> mapper, int bufferSize, Scheduler.Worker worker) (package private)
DebounceTimedObserver
(Observer<? super T> actual, long timeout, TimeUnit unit, Scheduler.Worker worker, Consumer<? super T> onDropped) (package private)
DebounceTimedObserver
(Observer<? super T> actual, long timeout, TimeUnit unit, Scheduler.Worker worker, Consumer<? super T> onDropped) (package private)
DelayObserver
(Observer<? super T> actual, long delay, TimeUnit unit, Scheduler.Worker w, boolean delayError) (package private)
ObserveOnObserver
(Observer<? super T> actual, Scheduler.Worker worker, boolean delayError, int bufferSize) (package private)
ThrottleLatestObserver
(Observer<? super T> downstream, long timeout, TimeUnit unit, Scheduler.Worker worker, boolean emitLast, Consumer<? super T> onDropped) (package private)
TimeoutFallbackObserver
(Observer<? super T> actual, long timeout, TimeUnit unit, Scheduler.Worker worker, ObservableSource<? extends T> fallback) (package private)
TimeoutObserver
(Observer<? super T> actual, long timeout, TimeUnit unit, Scheduler.Worker worker) (package private)
WindowSkipObserver
(Observer<? super Observable<T>> actual, long timespan, long timeskip, TimeUnit unit, Scheduler.Worker worker, int bufferSize) -
Uses of Scheduler.Worker in io.reactivex.rxjava3.internal.operators.parallel
Fields in io.reactivex.rxjava3.internal.operators.parallel declared as Scheduler.WorkerModifier and TypeFieldDescription(package private) final Scheduler.Worker
ParallelRunOn.BaseRunOnSubscriber.worker
Methods in io.reactivex.rxjava3.internal.operators.parallel with parameters of type Scheduler.WorkerModifier and TypeMethodDescription(package private) void
ParallelRunOn.createSubscriber
(int i, org.reactivestreams.Subscriber<? super T>[] subscribers, org.reactivestreams.Subscriber<T>[] parents, Scheduler.Worker worker) void
ParallelRunOn.MultiWorkerCallback.onWorker
(int i, Scheduler.Worker w) Constructors in io.reactivex.rxjava3.internal.operators.parallel with parameters of type Scheduler.WorkerModifierConstructorDescription(package private)
BaseRunOnSubscriber
(int prefetch, SpscArrayQueue<T> queue, Scheduler.Worker worker) (package private)
RunOnConditionalSubscriber
(ConditionalSubscriber<? super T> actual, int prefetch, SpscArrayQueue<T> queue, Scheduler.Worker worker) (package private)
RunOnSubscriber
(org.reactivestreams.Subscriber<? super T> actual, int prefetch, SpscArrayQueue<T> queue, Scheduler.Worker worker) -
Uses of Scheduler.Worker in io.reactivex.rxjava3.internal.schedulers
Subclasses of Scheduler.Worker in io.reactivex.rxjava3.internal.schedulersModifier and TypeClassDescription(package private) static final class
(package private) static final class
static final class
(package private) static final class
(package private) static final class
(package private) static final class
class
Base class that manages a single-threaded ScheduledExecutorService as a worker but doesn't perform task-tracking operations.(package private) static final class
(package private) static final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.schedulers declared as Scheduler.WorkerModifier and TypeFieldDescription(package private) final Scheduler.Worker
SchedulerWhen.CreateWorkerFunction.actualWorker
private final Scheduler.Worker
SchedulerWhen.QueueWorker.actualWorker
(package private) static final Scheduler.Worker
ImmediateThinScheduler.WORKER
Methods in io.reactivex.rxjava3.internal.schedulers that return Scheduler.WorkerModifier and TypeMethodDescriptionComputationScheduler.createWorker()
ExecutorScheduler.createWorker()
ImmediateThinScheduler.createWorker()
IoScheduler.createWorker()
NewThreadScheduler.createWorker()
SchedulerWhen.createWorker()
SingleScheduler.createWorker()
TrampolineScheduler.createWorker()
Methods in io.reactivex.rxjava3.internal.schedulers with parameters of type Scheduler.WorkerModifier and TypeMethodDescription(package private) void
SchedulerWhen.ScheduledAction.call
(Scheduler.Worker actualWorker, CompletableObserver actionCompletable) protected Disposable
SchedulerWhen.DelayedAction.callActual
(Scheduler.Worker actualWorker, CompletableObserver actionCompletable) protected Disposable
SchedulerWhen.ImmediateAction.callActual
(Scheduler.Worker actualWorker, CompletableObserver actionCompletable) protected abstract Disposable
SchedulerWhen.ScheduledAction.callActual
(Scheduler.Worker actualWorker, CompletableObserver actionCompletable) void
SchedulerMultiWorkerSupport.WorkerCallback.onWorker
(int index, Scheduler.Worker worker) Called with the Worker index and instance.Constructors in io.reactivex.rxjava3.internal.schedulers with parameters of type Scheduler.WorkerModifierConstructorDescription(package private)
CreateWorkerFunction
(Scheduler.Worker actualWorker) (package private)
QueueWorker
(FlowableProcessor<SchedulerWhen.ScheduledAction> actionProcessor, Scheduler.Worker actualWorker) -
Uses of Scheduler.Worker in io.reactivex.rxjava3.schedulers
Subclasses of Scheduler.Worker in io.reactivex.rxjava3.schedulersMethods in io.reactivex.rxjava3.schedulers that return Scheduler.Worker