Uses of Class
io.reactivex.rxjava3.core.Scheduler.Worker

Packages that use Scheduler.Worker

Package	Description
io.reactivex.rxjava3.core	Base reactive classes: Flowable, Observable, Single, Maybe and Completable; base reactive consumers; other common base interfaces.
io.reactivex.rxjava3.internal.operators.flowable
io.reactivex.rxjava3.internal.operators.observable
io.reactivex.rxjava3.internal.operators.parallel
io.reactivex.rxjava3.internal.schedulers
io.reactivex.rxjava3.schedulers	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.Worker

Modifier and Type	Field	Description
(package private) @NonNull Scheduler.Worker	Scheduler.DisposeTask.w
(package private) @NonNull Scheduler.Worker	Scheduler.PeriodicDirectTask.worker

Methods in io.reactivex.rxjava3.core that return Scheduler.Worker

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

Constructors in io.reactivex.rxjava3.core with parameters of type Scheduler.Worker

Constructor	Description
DisposeTask(@NonNull java.lang.Runnable decoratedRun, @NonNull Scheduler.Worker w)
PeriodicDirectTask(@NonNull java.lang.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.Worker

Modifier and Type	Field	Description
(package private) Scheduler.Worker	FlowableBufferTimed.BufferExactBoundedSubscriber.w
(package private) Scheduler.Worker	FlowableBufferTimed.BufferSkipBoundedSubscriber.w
(package private) Scheduler.Worker	FlowableDelay.DelaySubscriber.w
(package private) Scheduler.Worker	FlowableConcatMapScheduler.BaseConcatMapSubscriber.worker
(package private) Scheduler.Worker	FlowableDebounceTimed.DebounceTimedSubscriber.worker
(package private) Scheduler.Worker	FlowableObserveOn.BaseObserveOnSubscriber.worker
(package private) Scheduler.Worker	FlowableSubscribeOn.SubscribeOnSubscriber.worker
(package private) Scheduler.Worker	FlowableThrottleFirstTimed.DebounceTimedSubscriber.worker
(package private) Scheduler.Worker	FlowableThrottleLatest.ThrottleLatestSubscriber.worker
(package private) Scheduler.Worker	FlowableTimeoutTimed.TimeoutFallbackSubscriber.worker
(package private) Scheduler.Worker	FlowableTimeoutTimed.TimeoutSubscriber.worker
(package private) Scheduler.Worker	FlowableWindowTimed.WindowExactBoundedSubscriber.worker
(package private) Scheduler.Worker	FlowableWindowTimed.WindowSkipSubscriber.worker

Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type Scheduler.Worker

Constructor	Description
BaseConcatMapSubscriber(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch, Scheduler.Worker worker)
BaseObserveOnSubscriber(Scheduler.Worker worker, boolean delayError, int prefetch)
BufferExactBoundedSubscriber(org.reactivestreams.Subscriber<? super U> actual, Supplier<U> bufferSupplier, long timespan, java.util.concurrent.TimeUnit unit, int maxSize, boolean restartOnMaxSize, Scheduler.Worker w)
BufferSkipBoundedSubscriber(org.reactivestreams.Subscriber<? super U> actual, Supplier<U> bufferSupplier, long timespan, long timeskip, java.util.concurrent.TimeUnit unit, Scheduler.Worker w)
ConcatMapDelayed(org.reactivestreams.Subscriber<? super R> actual, Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch, boolean veryEnd, Scheduler.Worker worker)
ConcatMapImmediate(org.reactivestreams.Subscriber<? super R> actual, Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch, Scheduler.Worker worker)
DebounceTimedSubscriber(org.reactivestreams.Subscriber<? super T> actual, long timeout, java.util.concurrent.TimeUnit unit, Scheduler.Worker worker, Consumer<? super T> onDropped)
DebounceTimedSubscriber(org.reactivestreams.Subscriber<? super T> actual, long timeout, java.util.concurrent.TimeUnit unit, Scheduler.Worker worker, Consumer<? super T> onDropped)
DelaySubscriber(org.reactivestreams.Subscriber<? super T> actual, long delay, java.util.concurrent.TimeUnit unit, Scheduler.Worker w, boolean delayError)
ObserveOnConditionalSubscriber(ConditionalSubscriber<? super T> actual, Scheduler.Worker worker, boolean delayError, int prefetch)
ObserveOnSubscriber(org.reactivestreams.Subscriber<? super T> actual, Scheduler.Worker worker, boolean delayError, int prefetch)
SubscribeOnSubscriber(org.reactivestreams.Subscriber<? super T> actual, Scheduler.Worker worker, org.reactivestreams.Publisher<T> source, boolean requestOn)
ThrottleLatestSubscriber(org.reactivestreams.Subscriber<? super T> downstream, long timeout, java.util.concurrent.TimeUnit unit, Scheduler.Worker worker, boolean emitLast, Consumer<? super T> onDropped)
TimeoutFallbackSubscriber(org.reactivestreams.Subscriber<? super T> actual, long timeout, java.util.concurrent.TimeUnit unit, Scheduler.Worker worker, org.reactivestreams.Publisher<? extends T> fallback)
TimeoutSubscriber(org.reactivestreams.Subscriber<? super T> actual, long timeout, java.util.concurrent.TimeUnit unit, Scheduler.Worker worker)
WindowSkipSubscriber(org.reactivestreams.Subscriber<? super Flowable<T>> actual, long timespan, long timeskip, java.util.concurrent.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.Worker

Modifier and Type	Field	Description
(package private) Scheduler.Worker	ObservableBufferTimed.BufferExactBoundedObserver.w
(package private) Scheduler.Worker	ObservableBufferTimed.BufferSkipBoundedObserver.w
(package private) Scheduler.Worker	ObservableDelay.DelayObserver.w
(package private) Scheduler.Worker	ObservableConcatMapScheduler.ConcatMapDelayErrorObserver.worker
(package private) Scheduler.Worker	ObservableConcatMapScheduler.ConcatMapObserver.worker
(package private) Scheduler.Worker	ObservableDebounceTimed.DebounceTimedObserver.worker
(package private) Scheduler.Worker	ObservableObserveOn.ObserveOnObserver.worker
(package private) Scheduler.Worker	ObservableThrottleFirstTimed.DebounceTimedObserver.worker
(package private) Scheduler.Worker	ObservableThrottleLatest.ThrottleLatestObserver.worker
(package private) Scheduler.Worker	ObservableTimeoutTimed.TimeoutFallbackObserver.worker
(package private) Scheduler.Worker	ObservableTimeoutTimed.TimeoutObserver.worker
(package private) Scheduler.Worker	ObservableWindowTimed.WindowExactBoundedObserver.worker
(package private) Scheduler.Worker	ObservableWindowTimed.WindowSkipObserver.worker

Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type Scheduler.Worker

Constructor	Description
BufferExactBoundedObserver(Observer<? super U> actual, Supplier<U> bufferSupplier, long timespan, java.util.concurrent.TimeUnit unit, int maxSize, boolean restartOnMaxSize, Scheduler.Worker w)
BufferSkipBoundedObserver(Observer<? super U> actual, Supplier<U> bufferSupplier, long timespan, long timeskip, java.util.concurrent.TimeUnit unit, Scheduler.Worker w)
ConcatMapDelayErrorObserver(Observer<? super R> actual, Function<? super T,? extends ObservableSource<? extends R>> mapper, int bufferSize, boolean tillTheEnd, Scheduler.Worker worker)
ConcatMapObserver(Observer<? super U> actual, Function<? super T,? extends ObservableSource<? extends U>> mapper, int bufferSize, Scheduler.Worker worker)
DebounceTimedObserver(Observer<? super T> actual, long timeout, java.util.concurrent.TimeUnit unit, Scheduler.Worker worker, Consumer<? super T> onDropped)
DebounceTimedObserver(Observer<? super T> actual, long timeout, java.util.concurrent.TimeUnit unit, Scheduler.Worker worker, Consumer<? super T> onDropped)
DelayObserver(Observer<? super T> actual, long delay, java.util.concurrent.TimeUnit unit, Scheduler.Worker w, boolean delayError)
ObserveOnObserver(Observer<? super T> actual, Scheduler.Worker worker, boolean delayError, int bufferSize)
ThrottleLatestObserver(Observer<? super T> downstream, long timeout, java.util.concurrent.TimeUnit unit, Scheduler.Worker worker, boolean emitLast, Consumer<? super T> onDropped)
TimeoutFallbackObserver(Observer<? super T> actual, long timeout, java.util.concurrent.TimeUnit unit, Scheduler.Worker worker, ObservableSource<? extends T> fallback)
TimeoutObserver(Observer<? super T> actual, long timeout, java.util.concurrent.TimeUnit unit, Scheduler.Worker worker)
WindowSkipObserver(Observer<? super Observable<T>> actual, long timespan, long timeskip, java.util.concurrent.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.Worker

Modifier and Type	Field	Description
(package private) Scheduler.Worker	ParallelRunOn.BaseRunOnSubscriber.worker

Methods in io.reactivex.rxjava3.internal.operators.parallel with parameters of type Scheduler.Worker

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

Constructor	Description
BaseRunOnSubscriber(int prefetch, SpscArrayQueue<T> queue, Scheduler.Worker worker)
RunOnConditionalSubscriber(ConditionalSubscriber<? super T> actual, int prefetch, SpscArrayQueue<T> queue, Scheduler.Worker worker)
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.schedulers

Modifier and Type	Class	Description
(package private) static class	ComputationScheduler.EventLoopWorker
(package private) static class	ComputationScheduler.PoolWorker
static class	ExecutorScheduler.ExecutorWorker
(package private) static class	ImmediateThinScheduler.ImmediateThinWorker
(package private) static class	IoScheduler.EventLoopWorker
(package private) static class	IoScheduler.ThreadWorker
class	NewThreadWorker	Base class that manages a single-threaded ScheduledExecutorService as a worker but doesn't perform task-tracking operations.
(package private) static class	SchedulerWhen.QueueWorker
(package private) static class	SingleScheduler.ScheduledWorker
(package private) static class	TrampolineScheduler.TrampolineWorker

Fields in io.reactivex.rxjava3.internal.schedulers declared as Scheduler.Worker

Modifier and Type	Field	Description
(package private) Scheduler.Worker	SchedulerWhen.CreateWorkerFunction.actualWorker
private Scheduler.Worker	SchedulerWhen.QueueWorker.actualWorker
(package private) static Scheduler.Worker	ImmediateThinScheduler.WORKER

Methods in io.reactivex.rxjava3.internal.schedulers that return Scheduler.Worker

Modifier and Type	Method	Description
@NonNull Scheduler.Worker	ComputationScheduler.createWorker()
@NonNull Scheduler.Worker	ExecutorScheduler.createWorker()
@NonNull Scheduler.Worker	ImmediateThinScheduler.createWorker()
@NonNull Scheduler.Worker	IoScheduler.createWorker()
@NonNull Scheduler.Worker	NewThreadScheduler.createWorker()
@NonNull Scheduler.Worker	SchedulerWhen.createWorker()
@NonNull Scheduler.Worker	SingleScheduler.createWorker()
@NonNull Scheduler.Worker	TrampolineScheduler.createWorker()

Methods in io.reactivex.rxjava3.internal.schedulers with parameters of type Scheduler.Worker

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

Constructor	Description
CreateWorkerFunction(Scheduler.Worker actualWorker)
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.schedulers

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

Methods in io.reactivex.rxjava3.schedulers that return Scheduler.Worker

Modifier and Type	Method	Description
@NonNull Scheduler.Worker	TestScheduler.createWorker()