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
andCompletable
; 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 ofSchedulers
providing methods for retrieving the standard scheduler instances, theTestScheduler
for testing flows with scheduling in a controlled manner and the classTimed
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 newScheduler.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()
-