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

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

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

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

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

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

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

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

Modifier and Type	Class	Description
(package private) static final class	ComputationScheduler.EventLoopWorker
(package private) static final class	ComputationScheduler.PoolWorker
static final class	ExecutorScheduler.ExecutorWorker
(package private) static final class	ImmediateThinScheduler.ImmediateThinWorker
(package private) static final class	IoScheduler.EventLoopWorker
(package private) static final 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 final class	SchedulerWhen.QueueWorker
(package private) static final class	SingleScheduler.ScheduledWorker
(package private) static final class	TrampolineScheduler.TrampolineWorker

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

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

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

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

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

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