Uses of Class
io.reactivex.rxjava3.core.Scheduler
Packages that use Scheduler
Package
Description
Base reactive classes:
Flowable
, Observable
,
Single
, Maybe
and
Completable
; base reactive consumers;
other common base interfaces.Classes supporting the Flowable base reactive class:
ConnectableFlowable
and
GroupedFlowable
.Classes supporting the Observable base reactive class:
ConnectableObservable
and
GroupedObservable
.Contains the base type
ParallelFlowable
,
a sub-DSL for working with Flowable
sequences in parallel.Contains the central plugin handler
RxJavaPlugins
class to hook into the lifecycle of the base reactive types and schedulers.Classes representing so-called hot backpressure-aware sources, aka processors,
that implement the
FlowableProcessor
class,
the Reactive Streams Processor
interface
to allow forms of multicasting events to one or more subscribers as well as consuming another
Reactive Streams Publisher
.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.Classes representing so-called hot sources, aka subjects, that implement a base reactive class and
the respective consumer type at once to allow forms of multicasting events to multiple
consumers as well as consuming another base reactive type of their kind.
-
Uses of Scheduler in io.reactivex.rxjava3.core
Methods in io.reactivex.rxjava3.core with type parameters of type SchedulerModifier and TypeMethodDescription<S extends Scheduler & Disposable>
SScheduler.when
(@NonNull Function<Flowable<Flowable<Completable>>, Completable> combine) Allows the use of operators for controlling the timing around when actions scheduled on workers are actually done.Methods in io.reactivex.rxjava3.core with parameters of type SchedulerModifier and TypeMethodDescriptionReturns aFlowable
that emits buffers of items it collects from the currentFlowable
.Flowable.buffer
(long timespan, long timeskip, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Supplier<@NonNull U> bufferSupplier) Returns aFlowable
that emits buffers of items it collects from the currentFlowable
.Returns aFlowable
that emits buffers of items it collects from the currentFlowable
.Returns aFlowable
that emits buffers of items it collects from the currentFlowable
.Flowable.buffer
(long timespan, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, int count, @NonNull Supplier<@NonNull U> bufferSupplier, boolean restartTimerOnMaxSize) Returns aFlowable
that emits buffers of items it collects from the currentFlowable
.final @NonNull Observable
<@NonNull List<T>> Observable.buffer
(long timespan, long timeskip, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Returns anObservable
that emits buffers of items it collects from the currentObservable
.final <@NonNull U extends Collection<? super @NonNull T>>
@NonNull Observable<U> Observable.buffer
(long timespan, long timeskip, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Supplier<@NonNull U> bufferSupplier) Returns anObservable
that emits buffers of items it collects from the currentObservable
.final @NonNull Observable
<@NonNull List<T>> Returns anObservable
that emits buffers of items it collects from the currentObservable
.final @NonNull Observable
<@NonNull List<T>> Returns anObservable
that emits buffers of items it collects from the currentObservable
.final <@NonNull U extends Collection<? super @NonNull T>>
@NonNull Observable<U> Observable.buffer
(long timespan, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, int count, @NonNull Supplier<@NonNull U> bufferSupplier, boolean restartTimerOnMaxSize) Returns anObservable
that emits buffers of items it collects from the currentObservable
.Flowable.concatMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, int prefetch, @NonNull Scheduler scheduler) Returns a newFlowable
that emits items resulting from applying a function (on a designated scheduler) that you supply to each item emitted by the currentFlowable
, where that function returns aPublisher
, and then emitting the items that result from concatenating those returnedPublisher
s.final <@NonNull R>
@NonNull Observable<R> Observable.concatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper, int bufferSize, @NonNull Scheduler scheduler) Returns a newObservable
that emits items resulting from applying a function that you supply to each item emitted by the currentObservable
, where that function returns anObservableSource
, and then emitting the items that result from concatenating those returnedObservableSource
s.Flowable.concatMapDelayError
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, boolean tillTheEnd, int prefetch, @NonNull Scheduler scheduler) Maps each of the upstream items into aPublisher
, subscribes to them one after the other, one at a time and emits their values in order while executing the mapper function on the designated scheduler, delaying any error from either this or any of the innerPublisher
s till all of them terminate.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapDelayError
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper, boolean tillTheEnd, int bufferSize, @NonNull Scheduler scheduler) Maps each of the items into anObservableSource
, subscribes to them one after the other, one at a time and emits their values in order while delaying any error from either this or any of the innerObservableSource
s till all of them terminate.Returns aFlowable
that mirrors the currentFlowable
, except that it drops items emitted by the currentFlowable
that are followed by newer items before a timeout value expires on a specifiedScheduler
.Flowable.debounce
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Consumer<? super @NonNull T> onDropped) Returns aFlowable
that mirrors the currentFlowable
, except that it drops items emitted by the currentFlowable
that are followed by newer items before a timeout value expires on a specifiedScheduler
.final @NonNull Observable
<T> Returns anObservable
that mirrors the currentObservable
, except that it drops items emitted by the currentObservable
that are followed by newer items before a timeout value expires on a specifiedScheduler
.final @NonNull Observable
<T> Observable.debounce
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Consumer<? super @NonNull T> onDropped) Returns anObservable
that mirrors the currentObservable
, except that it drops items emitted by the currentObservable
that are followed by newer items before a timeout value expires on a specifiedScheduler
.final @NonNull Completable
Returns aCompletable
which delays the emission of the completion event by the given time while running on the specifiedScheduler
.final @NonNull Completable
Completable.delay
(long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean delayError) Returns aCompletable
which delays the emission of the completion event, and optionally the error as well, by the given time while running on the specifiedScheduler
.Returns aFlowable
that emits the items emitted by the currentFlowable
shifted forward in time by a specified delay.Returns aFlowable
that emits the items emitted by the currentFlowable
shifted forward in time by a specified delay.Returns aMaybe
that signals the events emitted by the currentMaybe
shifted forward in time by a specified delay.Returns aMaybe
that signals the events emitted by the currentMaybe
shifted forward in time by a specified delay running on the specifiedScheduler
.final @NonNull Observable
<T> Returns anObservable
that emits the items emitted by the currentObservable
shifted forward in time by a specified delay.final @NonNull Observable
<T> Observable.delay
(long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean delayError) Returns anObservable
that emits the items emitted by the currentObservable
shifted forward in time by a specified delay.Delays the emission of the success signal from the currentSingle
by the specified amount.Delays the emission of the success or error signal from the currentSingle
by the specified amount.final @NonNull Completable
Completable.delaySubscription
(long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Returns aCompletable
that delays the subscription to the upstream by a given amount of time, both waiting and subscribing on a givenScheduler
.Flowable.delaySubscription
(long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Returns aFlowable
that delays the subscription to the currentFlowable
by a given amount of time, both waiting and subscribing on a givenScheduler
.Maybe.delaySubscription
(long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Returns aMaybe
that delays the subscription to the currentMaybe
by a given amount of time, both waiting and subscribing on a givenScheduler
.final @NonNull Observable
<T> Observable.delaySubscription
(long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Returns anObservable
that delays the subscription to the currentObservable
by a given amount of time, both waiting and subscribing on a givenScheduler
.Single.delaySubscription
(long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Delays the actual subscription to the currentSingle
until the given time delay elapsed.Flowable.interval
(long initialDelay, long period, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Returns aFlowable
that emits a0L
after theinitialDelay
and ever-increasing numbers after eachperiod
of time thereafter, on a specifiedScheduler
.Returns aFlowable
that emits a sequential number every specified interval of time, on a specifiedScheduler
.static @NonNull Observable
<Long> Observable.interval
(long initialDelay, long period, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Returns anObservable
that emits a0L
after theinitialDelay
and ever increasing numbers after eachperiod
of time thereafter, on a specifiedScheduler
.static @NonNull Observable
<Long> Returns anObservable
that emits a sequential number every specified interval of time, on a specifiedScheduler
.Flowable.intervalRange
(long start, long count, long initialDelay, long period, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Signals a range of long values, the first after some initial delay and the rest periodically after.static @NonNull Observable
<Long> Observable.intervalRange
(long start, long count, long initialDelay, long period, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Signals a range of long values, the first after some initial delay and the rest periodically after.final @NonNull Completable
Returns aCompletable
which emits the terminal events from the thread of the specifiedScheduler
.Signals the items and terminal signals of the currentFlowable
on the specifiedScheduler
, asynchronously with a bounded buffer ofFlowable.bufferSize()
slots.Signals the items and terminal signals of the currentFlowable
on the specifiedScheduler
, asynchronously with a bounded buffer and optionally delaysonError
notifications.Signals the items and terminal signals of the currentFlowable
on the specifiedScheduler
, asynchronously with a bounded buffer of configurable size and optionally delaysonError
notifications.Wraps aMaybe
to emit its item (or notify of its error) on a specifiedScheduler
, asynchronously.final @NonNull Observable
<T> Returns anObservable
to perform the currentObservable
's emissions and notifications on a specifiedScheduler
, asynchronously with an unbounded buffer withFlowable.bufferSize()
"island size".final @NonNull Observable
<T> Returns anObservable
to perform the currentObservable
's emissions and notifications on a specifiedScheduler
, asynchronously with an unbounded buffer withFlowable.bufferSize()
"island size" and optionally delaysonError
notifications.final @NonNull Observable
<T> Returns anObservable
to perform the currentObservable
's emissions and notifications on a specifiedScheduler
, asynchronously with an unbounded buffer of configurable "island size" and optionally delaysonError
notifications.Signals the success item or the terminal signals of the currentSingle
on the specifiedScheduler
, asynchronously.final @NonNull ConnectableFlowable
<T> Returns aConnectableFlowable
that shares a single subscription to the currentFlowable
and replays a maximum ofbufferSize
items that are emitted within a specified time window to lateSubscriber
s.final @NonNull ConnectableFlowable
<T> Flowable.replay
(int bufferSize, long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean eagerTruncate) Returns aConnectableFlowable
that shares a single subscription to the currentFlowable
and replays a maximum ofbufferSize
items that are emitted within a specified time window to lateSubscriber
s.final @NonNull ConnectableFlowable
<T> Returns aConnectableFlowable
that shares a single subscription to the currentFlowable
and replays all items emitted by it within a specified time window to lateSubscriber
s.final @NonNull ConnectableFlowable
<T> Flowable.replay
(long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean eagerTruncate) Returns aConnectableFlowable
that shares a single subscription to the currentFlowable
and replays all items emitted by it within a specified time window to lateSubscriber
s.Flowable.replay
(@NonNull Function<? super Flowable<@NonNull T>, @NonNull ? extends org.reactivestreams.Publisher<@NonNull R>> selector, int bufferSize, long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Returns aFlowable
that emits items that are the results of invoking a specified selector on items emitted by aConnectableFlowable
that shares a single subscription to the currentFlowable
, replaying no more thanbufferSize
items that were emitted within a specified time window.Flowable.replay
(@NonNull Function<? super Flowable<@NonNull T>, @NonNull ? extends org.reactivestreams.Publisher<@NonNull R>> selector, int bufferSize, long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean eagerTruncate) Returns aFlowable
that emits items that are the results of invoking a specified selector on items emitted by aConnectableFlowable
that shares a single subscription to the currentFlowable
, replaying no more thanbufferSize
items that were emitted within a specified time window.Flowable.replay
(@NonNull Function<? super Flowable<@NonNull T>, @NonNull ? extends org.reactivestreams.Publisher<@NonNull R>> selector, long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Returns aFlowable
that emits items that are the results of invoking a specified selector on items emitted by aConnectableFlowable
that shares a single subscription to the currentFlowable
, replaying all items that were emitted within a specified time window.Flowable.replay
(@NonNull Function<? super Flowable<@NonNull T>, @NonNull ? extends org.reactivestreams.Publisher<@NonNull R>> selector, long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean eagerTruncate) Returns aFlowable
that emits items that are the results of invoking a specified selector on items emitted by aConnectableFlowable
that shares a single subscription to the currentFlowable
, replaying all items that were emitted within a specified time window.final @NonNull ConnectableObservable
<T> Returns aConnectableObservable
that shares a single subscription to the currentObservable
and that replays a maximum ofbufferSize
items that are emitted within a specified time window.final @NonNull ConnectableObservable
<T> Observable.replay
(int bufferSize, long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean eagerTruncate) Returns aConnectableObservable
that shares a single subscription to the currentObservable
and that replays a maximum ofbufferSize
items that are emitted within a specified time window.final @NonNull ConnectableObservable
<T> Returns aConnectableObservable
that shares a single subscription to the currentObservable
and replays all items emitted by the currentObservable
within a specified time window.final @NonNull ConnectableObservable
<T> Observable.replay
(long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean eagerTruncate) Returns aConnectableObservable
that shares a single subscription to the currentObservable
and replays all items emitted by the currentObservable
within a specified time window.final <@NonNull R>
@NonNull Observable<R> Observable.replay
(@NonNull Function<? super Observable<@NonNull T>, ? extends ObservableSource<@NonNull R>> selector, int bufferSize, long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Returns anObservable
that emits items that are the results of invoking a specified selector on items emitted by aConnectableObservable
that shares a single subscription to the currentObservable
, replaying no more thanbufferSize
items that were emitted within a specified time window.final <@NonNull R>
@NonNull Observable<R> Observable.replay
(@NonNull Function<? super Observable<@NonNull T>, ? extends ObservableSource<@NonNull R>> selector, int bufferSize, long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean eagerTruncate) Returns anObservable
that emits items that are the results of invoking a specified selector on items emitted by aConnectableObservable
that shares a single subscription to the currentObservable
, replaying no more thanbufferSize
items that were emitted within a specified time window.final <@NonNull R>
@NonNull Observable<R> Observable.replay
(@NonNull Function<? super Observable<@NonNull T>, ? extends ObservableSource<@NonNull R>> selector, long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Returns anObservable
that emits items that are the results of invoking a specified selector on items emitted by aConnectableObservable
that shares a single subscription to the currentObservable
, replaying all items that were emitted within a specified time window.final <@NonNull R>
@NonNull Observable<R> Observable.replay
(@NonNull Function<? super Observable<@NonNull T>, ? extends ObservableSource<@NonNull R>> selector, long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean eagerTruncate) Returns anObservable
that emits items that are the results of invoking a specified selector on items emitted by aConnectableObservable
that shares a single subscription to the currentObservable
, replaying all items that were emitted within a specified time window.Returns aFlowable
that emits the most recently emitted item (if any) emitted by the currentFlowable
within periodic time intervals, where the intervals are defined on a particularScheduler
.Flowable.sample
(long period, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean emitLast) Returns aFlowable
that emits the most recently emitted item (if any) emitted by the currentFlowable
within periodic time intervals, where the intervals are defined on a particularScheduler
and optionally emit the very last upstream item when the upstream completes.Flowable.sample
(long period, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean emitLast, @NonNull Consumer<? super @NonNull T> onDropped) Returns aFlowable
that emits the most recently emitted item (if any) emitted by the currentFlowable
within periodic time intervals, where the intervals are defined on a particularScheduler
and optionally emit the very last upstream item when the upstream completes.final @NonNull Observable
<T> Returns anObservable
that emits the most recently emitted item (if any) emitted by the currentObservable
within periodic time intervals, where the intervals are defined on a particularScheduler
.final @NonNull Observable
<T> Observable.sample
(long period, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean emitLast) Returns anObservable
that emits the most recently emitted item (if any) emitted by the currentObservable
within periodic time intervals, where the intervals are defined on a particularScheduler
and optionally emit the very last upstream item when the upstream completes.final @NonNull Observable
<T> Observable.sample
(long period, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean emitLast, @NonNull Consumer<? super @NonNull T> onDropped) Returns anObservable
that emits the most recently emitted item (if any) emitted by the currentObservable
within periodic time intervals, where the intervals are defined on a particularScheduler
.Returns aFlowable
that skips values emitted by the currentFlowable
before a specified time window on a specifiedScheduler
elapses.final @NonNull Observable
<T> Returns anObservable
that skips values emitted by the currentObservable
before a specified time window on a specifiedScheduler
elapses.Returns aFlowable
that drops items emitted by the currentFlowable
during a specified time window (defined on a specified scheduler) before the source completes.Flowable.skipLast
(long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean delayError) Returns aFlowable
that drops items emitted by the currentFlowable
during a specified time window (defined on a specified scheduler) before the source completes.Flowable.skipLast
(long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean delayError, int bufferSize) Returns aFlowable
that drops items emitted by the currentFlowable
during a specified time window (defined on a specified scheduler) before the source completes.final @NonNull Observable
<T> Returns anObservable
that drops items emitted by the currentObservable
during a specified time window (defined on a specified scheduler) before the source completes.final @NonNull Observable
<T> Observable.skipLast
(long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean delayError) Returns anObservable
that drops items emitted by the currentObservable
during a specified time window (defined on a specified scheduler) before the source completes.final @NonNull Observable
<T> Observable.skipLast
(long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean delayError, int bufferSize) Returns anObservable
that drops items emitted by the currentObservable
during a specified time window (defined on a specified scheduler) before the source completes.final @NonNull Completable
Completable.subscribeOn
(@NonNull Scheduler scheduler) Returns aCompletable
which subscribes the downstream subscriber on the specified scheduler, making sure the subscription side-effects happen on that specific thread of theScheduler
.Flowable.subscribeOn
(@NonNull Scheduler scheduler) Flowable.subscribeOn
(@NonNull Scheduler scheduler, boolean requestOn) Asynchronously subscribesSubscriber
s to the currentFlowable
on the specifiedScheduler
optionally reroutes requests from other threads to the sameScheduler
thread.Maybe.subscribeOn
(@NonNull Scheduler scheduler) Asynchronously subscribes subscribers to thisMaybe
on the specifiedScheduler
.final @NonNull Observable
<T> Observable.subscribeOn
(@NonNull Scheduler scheduler) Single.subscribeOn
(@NonNull Scheduler scheduler) Returns aFlowable
that emits those items emitted by sourcePublisher
before a specified time (on a specifiedScheduler
) runs out.final @NonNull Observable
<T> Returns anObservable
that emits those items emitted by the currentObservable
before a specified time (on a specifiedScheduler
) runs out.Returns aFlowable
that emits at most a specified number of items from the currentFlowable
that were emitted in a specified window of time before the currentFlowable
completed, where the timing information is provided by a givenScheduler
.Flowable.takeLast
(long count, long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean delayError, int bufferSize) Returns aFlowable
that emits at most a specified number of items from the currentFlowable
that were emitted in a specified window of time before the currentFlowable
completed, where the timing information is provided by a givenScheduler
.Returns aFlowable
that emits the items from the currentFlowable
that were emitted in a specified window of time before the currentFlowable
completed, where the timing information is provided by a specifiedScheduler
.Flowable.takeLast
(long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean delayError) Returns aFlowable
that emits the items from the currentFlowable
that were emitted in a specified window of time before the currentFlowable
completed, where the timing information is provided by a specifiedScheduler
.Flowable.takeLast
(long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean delayError, int bufferSize) Returns aFlowable
that emits the items from the currentFlowable
that were emitted in a specified window of time before the currentFlowable
completed, where the timing information is provided by a specifiedScheduler
.final @NonNull Observable
<T> Returns anObservable
that emits at most a specified number of items from the currentObservable
that were emitted in a specified window of time before the currentObservable
completed, where the timing information is provided by a givenScheduler
.final @NonNull Observable
<T> Observable.takeLast
(long count, long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean delayError, int bufferSize) Returns anObservable
that emits at most a specified number of items from the currentObservable
that were emitted in a specified window of time before the currentObservable
completed, where the timing information is provided by a givenScheduler
.final @NonNull Observable
<T> Returns anObservable
that emits the items from the currentObservable
that were emitted in a specified window of time before the currentObservable
completed, where the timing information is provided by a specifiedScheduler
.final @NonNull Observable
<T> Observable.takeLast
(long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean delayError) Returns anObservable
that emits the items from the currentObservable
that were emitted in a specified window of time before the currentObservable
completed, where the timing information is provided by a specifiedScheduler
.final @NonNull Observable
<T> Observable.takeLast
(long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean delayError, int bufferSize) Returns anObservable
that emits the items from the currentObservable
that were emitted in a specified window of time before the currentObservable
completed, where the timing information is provided by a specifiedScheduler
.Flowable.throttleFirst
(long skipDuration, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Returns aFlowable
that emits only the first item emitted by the currentFlowable
during sequential time windows of a specified duration, where the windows are managed by a specifiedScheduler
.Flowable.throttleFirst
(long skipDuration, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Consumer<? super @NonNull T> onDropped) Returns aFlowable
that emits only the first item emitted by the currentFlowable
during sequential time windows of a specified duration, where the windows are managed by a specifiedScheduler
.final @NonNull Observable
<T> Observable.throttleFirst
(long skipDuration, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Returns anObservable
that emits only the first item emitted by the currentObservable
during sequential time windows of a specified duration, where the windows are managed by a specifiedScheduler
.final @NonNull Observable
<T> Observable.throttleFirst
(long skipDuration, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Consumer<? super @NonNull T> onDropped) Returns anObservable
that emits only the first item emitted by the currentObservable
during sequential time windows of a specified duration, where the windows are managed by a specifiedScheduler
.Flowable.throttleLast
(long intervalDuration, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Returns aFlowable
that emits only the last item emitted by the currentFlowable
during sequential time windows of a specified duration, where the duration is governed by a specifiedScheduler
.Flowable.throttleLast
(long intervalDuration, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Consumer<? super @NonNull T> onDropped) Returns aFlowable
that emits only the last item emitted by the currentFlowable
during sequential time windows of a specified duration, where the duration is governed by a specifiedScheduler
.final @NonNull Observable
<T> Observable.throttleLast
(long intervalDuration, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Returns anObservable
that emits only the last item emitted by the currentObservable
during sequential time windows of a specified duration, where the duration is governed by a specifiedScheduler
.final @NonNull Observable
<T> Observable.throttleLast
(long intervalDuration, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Consumer<? super @NonNull T> onDropped) Returns anObservable
that emits only the last item emitted by the currentObservable
during sequential time windows of a specified duration, where the duration is governed by a specifiedScheduler
.Flowable.throttleLatest
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Throttles items from the upstreamFlowable
by first emitting the next item from upstream, then periodically emitting the latest item (if any) when the specified timeout elapses between them.Flowable.throttleLatest
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean emitLast) Throttles items from the upstreamFlowable
by first emitting the next item from upstream, then periodically emitting the latest item (if any) when the specified timeout elapses between them.Flowable.throttleLatest
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean emitLast, @NonNull Consumer<? super @NonNull T> onDropped) Throttles items from the upstreamFlowable
by first emitting the next item from upstream, then periodically emitting the latest item (if any) when the specified timeout elapses between them, invoking the consumer for any dropped item.final @NonNull Observable
<T> Observable.throttleLatest
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Throttles items from the currentObservable
by first emitting the next item from upstream, then periodically emitting the latest item (if any) when the specified timeout elapses between them.final @NonNull Observable
<T> Observable.throttleLatest
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean emitLast) Throttles items from the currentObservable
by first emitting the next item from upstream, then periodically emitting the latest item (if any) when the specified timeout elapses between them.final @NonNull Observable
<T> Observable.throttleLatest
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean emitLast, @NonNull Consumer<? super @NonNull T> onDropped) Throttles items from the currentObservable
by first emitting the next item from upstream, then periodically emitting the latest item (if any) when the specified timeout elapses between them, invoking the consumer for any dropped item.Flowable.throttleWithTimeout
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Returns aFlowable
that mirrors the currentFlowable
, except that it drops items emitted by the currentFlowable
that are followed by newer items before a timeout value expires on a specifiedScheduler
.Flowable.throttleWithTimeout
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Consumer<? super @NonNull T> onDropped) Returns aFlowable
that mirrors the currentFlowable
, except that it drops items emitted by the currentFlowable
that are followed by newer items before a timeout value expires on a specifiedScheduler
.final @NonNull Observable
<T> Observable.throttleWithTimeout
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Returns anObservable
that mirrors the currentObservable
, except that it drops items emitted by the currentObservable
that are followed by newer items before a timeout value expires on a specifiedScheduler
.final @NonNull Observable
<T> Observable.throttleWithTimeout
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Consumer<? super @NonNull T> onDropped) Returns anObservable
that mirrors the currentObservable
, except that it drops items emitted by the currentObservable
that are followed by newer items before a timeout value expires on a specifiedScheduler
.Flowable.timeInterval
(@NonNull Scheduler scheduler) Returns aFlowable
that emits records of the time interval between consecutive items emitted by the currentFlowable
, where this interval is computed on a specifiedScheduler
.Flowable.timeInterval
(@NonNull TimeUnit unit, @NonNull Scheduler scheduler) Returns aFlowable
that emits records of the time interval between consecutive items emitted by the currentFlowable
, where this interval is computed on a specifiedScheduler
.Maybe.timeInterval
(@NonNull Scheduler scheduler) Measures the time (in milliseconds) between the subscription and success item emission of the currentMaybe
and signals it as a tuple (Timed
) success value.Maybe.timeInterval
(@NonNull TimeUnit unit, @NonNull Scheduler scheduler) Measures the time between the subscription and success item emission of the currentMaybe
and signals it as a tuple (Timed
) success value.final @NonNull Observable
<Timed<T>> Observable.timeInterval
(@NonNull Scheduler scheduler) Returns anObservable
that emits records of the time interval between consecutive items emitted by the currentObservable
, where this interval is computed on a specifiedScheduler
.final @NonNull Observable
<Timed<T>> Observable.timeInterval
(@NonNull TimeUnit unit, @NonNull Scheduler scheduler) Returns anObservable
that emits records of the time interval between consecutive items emitted by the currentObservable
, where this interval is computed on a specifiedScheduler
.Single.timeInterval
(@NonNull Scheduler scheduler) Measures the time (in milliseconds) between the subscription and success item emission of the currentSingle
and signals it as a tuple (Timed
) success value.Single.timeInterval
(@NonNull TimeUnit unit, @NonNull Scheduler scheduler) Measures the time between the subscription and success item emission of the currentSingle
and signals it as a tuple (Timed
) success value.final @NonNull Completable
Returns aCompletable
that runs thisCompletable
and emits aTimeoutException
in case thisCompletable
doesn't complete within the given time while "waiting" on the specifiedScheduler
.final @NonNull Completable
Completable.timeout
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull CompletableSource fallback) Returns aCompletable
that runs thisCompletable
and switches to the otherCompletableSource
in case thisCompletable
doesn't complete within the given time while "waiting" on the specifiedScheduler
.Returns aFlowable
that mirrors the currentFlowable
but applies a timeout policy for each emitted item, where this policy is governed by a specifiedScheduler
.Flowable.timeout
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull org.reactivestreams.Publisher<? extends @NonNull T> fallback) Returns aFlowable
that mirrors the currentFlowable
but applies a timeout policy for each emitted item using a specifiedScheduler
.Returns aMaybe
that mirrors the currentMaybe
but applies a timeout policy for each emitted item, where this policy is governed on a specifiedScheduler
.Maybe.timeout
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull MaybeSource<? extends @NonNull T> fallback) Returns aMaybe
that mirrors the currentMaybe
but applies a timeout policy for each emitted item using a specifiedScheduler
.final @NonNull Observable
<T> Returns anObservable
that mirrors the currentObservable
but applies a timeout policy for each emitted item, where this policy is governed on a specifiedScheduler
.final @NonNull Observable
<T> Observable.timeout
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull ObservableSource<? extends @NonNull T> fallback) Returns anObservable
that mirrors the currentObservable
but applies a timeout policy for each emitted item using a specifiedScheduler
.Signals aTimeoutException
if the currentSingle
doesn't signal a success value within the specified timeout window.Single.timeout
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull SingleSource<? extends @NonNull T> fallback) Runs the currentSingle
and if it doesn't signal within the specified timeout window, it is disposed and the otherSingleSource
subscribed to.private @NonNull Completable
Completable.timeout0
(long timeout, TimeUnit unit, Scheduler scheduler, CompletableSource fallback) Returns aCompletable
that runs thisCompletable
and optionally switches to the otherCompletableSource
in case thisCompletable
doesn't complete within the given time while "waiting" on the specifiedScheduler
.Flowable.timeout0
(long timeout, TimeUnit unit, org.reactivestreams.Publisher<? extends @NonNull T> fallback, Scheduler scheduler) private @NonNull Observable
<T> Observable.timeout0
(long timeout, @NonNull TimeUnit unit, @Nullable ObservableSource<? extends @NonNull T> fallback, @NonNull Scheduler scheduler) Single.timeout0
(long timeout, TimeUnit unit, Scheduler scheduler, SingleSource<? extends @NonNull T> fallback) static @NonNull Completable
Returns aCompletable
instance that fires itsonComplete
event after the given delay elapsed by using the suppliedScheduler
.Returns aFlowable
that emits0L
after a specified delay, on a specifiedScheduler
, and then completes.static @NonNull Observable
<Long> Returns anObservable
that emits0L
after a specified delay, on a specifiedScheduler
, and then completes.Signals success with 0L value on the specifiedScheduler
after the given delay when aSingleObserver
subscribes.final @NonNull Observable
<Timed<T>> final @NonNull Observable
<Timed<T>> final @NonNull Completable
Completable.unsubscribeOn
(@NonNull Scheduler scheduler) Returns aCompletable
which makes sure when an observer disposes the subscription, thedispose()
method is called on the specifiedScheduler
.Flowable.unsubscribeOn
(@NonNull Scheduler scheduler) Cancels the currentFlowable
asynchronously by invokingSubscription.cancel()
on the specifiedScheduler
.Maybe.unsubscribeOn
(@NonNull Scheduler scheduler) Returns aMaybe
which makes sure when aMaybeObserver
disposes theDisposable
, that call is propagated up on the specifiedScheduler
.final @NonNull Observable
<T> Observable.unsubscribeOn
(@NonNull Scheduler scheduler) Single.unsubscribeOn
(@NonNull Scheduler scheduler) Returns aSingle
which makes sure when aSingleObserver
disposes theDisposable
, that call is propagated up on the specifiedScheduler
.Returns aFlowable
that emits windows of items it collects from the currentFlowable
.Flowable.window
(long timespan, long timeskip, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, int bufferSize) Returns aFlowable
that emits windows of items it collects from the currentFlowable
.Returns aFlowable
that emits windows of items it collects from the currentFlowable
.Returns aFlowable
that emits windows of items it collects from the currentFlowable
.Flowable.window
(long timespan, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, long count, boolean restart) Returns aFlowable
that emits windows of items it collects from the currentFlowable
.Flowable.window
(long timespan, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, long count, boolean restart, int bufferSize) Returns aFlowable
that emits windows of items it collects from the currentFlowable
.final @NonNull Observable
<Observable<T>> Observable.window
(long timespan, long timeskip, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Returns anObservable
that emits windows of items it collects from the currentObservable
.final @NonNull Observable
<Observable<T>> Observable.window
(long timespan, long timeskip, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, int bufferSize) Returns anObservable
that emits windows of items it collects from the currentObservable
.final @NonNull Observable
<Observable<T>> Returns anObservable
that emits windows of items it collects from the currentObservable
.final @NonNull Observable
<Observable<T>> Returns anObservable
that emits windows of items it collects from the currentObservable
.final @NonNull Observable
<Observable<T>> Observable.window
(long timespan, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, long count, boolean restart) Returns anObservable
that emits windows of items it collects from the currentObservable
.final @NonNull Observable
<Observable<T>> Observable.window
(long timespan, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, long count, boolean restart, int bufferSize) Returns anObservable
that emits windows of items it collects from the currentObservable
. -
Uses of Scheduler in io.reactivex.rxjava3.flowables
Methods in io.reactivex.rxjava3.flowables with parameters of type SchedulerModifier and TypeMethodDescriptionConnectableFlowable.refCount
(int subscriberCount, long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Connects to the upstreamConnectableFlowable
if the number of subscribed subscriber reaches the specified count and disconnect after the specified timeout if all subscribers have unsubscribed.Connects to the upstreamConnectableFlowable
if the number of subscribed subscriber reaches 1 and disconnect after the specified timeout if all subscribers have unsubscribed. -
Uses of Scheduler in io.reactivex.rxjava3.internal.functions
Fields in io.reactivex.rxjava3.internal.functions declared as SchedulerModifier and TypeFieldDescription(package private) final Scheduler
Functions.TimestampFunction.scheduler
Methods in io.reactivex.rxjava3.internal.functions with parameters of type SchedulerConstructors in io.reactivex.rxjava3.internal.functions with parameters of type SchedulerModifierConstructorDescription(package private)
TimestampFunction
(TimeUnit unit, Scheduler scheduler) -
Uses of Scheduler in io.reactivex.rxjava3.internal.operators.completable
Fields in io.reactivex.rxjava3.internal.operators.completable declared as SchedulerModifier and TypeFieldDescription(package private) final Scheduler
CompletableDelay.Delay.scheduler
(package private) final Scheduler
CompletableDelay.scheduler
(package private) final Scheduler
CompletableDisposeOn.DisposeOnObserver.scheduler
(package private) final Scheduler
CompletableDisposeOn.scheduler
(package private) final Scheduler
CompletableObserveOn.ObserveOnCompletableObserver.scheduler
(package private) final Scheduler
CompletableObserveOn.scheduler
(package private) final Scheduler
CompletableSubscribeOn.scheduler
(package private) final Scheduler
CompletableTimeout.scheduler
(package private) final Scheduler
CompletableTimer.scheduler
Constructors in io.reactivex.rxjava3.internal.operators.completable with parameters of type SchedulerModifierConstructorDescriptionCompletableDelay
(CompletableSource source, long delay, TimeUnit unit, Scheduler scheduler, boolean delayError) CompletableDisposeOn
(CompletableSource source, Scheduler scheduler) CompletableObserveOn
(CompletableSource source, Scheduler scheduler) CompletableSubscribeOn
(CompletableSource source, Scheduler scheduler) CompletableTimeout
(CompletableSource source, long timeout, TimeUnit unit, Scheduler scheduler, CompletableSource other) CompletableTimer
(long delay, TimeUnit unit, Scheduler scheduler) (package private)
Delay
(CompletableObserver downstream, long delay, TimeUnit unit, Scheduler scheduler, boolean delayError) (package private)
DisposeOnObserver
(CompletableObserver observer, Scheduler scheduler) (package private)
ObserveOnCompletableObserver
(CompletableObserver actual, Scheduler scheduler) -
Uses of Scheduler in io.reactivex.rxjava3.internal.operators.flowable
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as SchedulerModifier and TypeFieldDescription(package private) final Scheduler
FlowableBufferTimed.BufferExactUnboundedSubscriber.scheduler
(package private) final Scheduler
FlowableBufferTimed.scheduler
(package private) final Scheduler
FlowableConcatMapScheduler.scheduler
(package private) final Scheduler
FlowableDebounceTimed.scheduler
(package private) final Scheduler
FlowableDelay.scheduler
(package private) final Scheduler
FlowableInternalHelper.BufferedTimedReplay.scheduler
private final Scheduler
FlowableInternalHelper.TimedReplay.scheduler
(package private) final Scheduler
FlowableInterval.scheduler
(package private) final Scheduler
FlowableIntervalRange.scheduler
(package private) final Scheduler
FlowableObserveOn.scheduler
(package private) final Scheduler
FlowableRefCount.scheduler
private final Scheduler
FlowableReplay.ScheduledReplayBufferSupplier.scheduler
(package private) final Scheduler
FlowableReplay.SizeAndTimeBoundReplayBuffer.scheduler
(package private) final Scheduler
FlowableSampleTimed.SampleTimedSubscriber.scheduler
(package private) final Scheduler
FlowableSampleTimed.scheduler
(package private) final Scheduler
FlowableSkipLastTimed.scheduler
(package private) final Scheduler
FlowableSkipLastTimed.SkipLastTimedSubscriber.scheduler
(package private) final Scheduler
FlowableSubscribeOn.scheduler
(package private) final Scheduler
FlowableTakeLastTimed.scheduler
(package private) final Scheduler
FlowableTakeLastTimed.TakeLastTimedSubscriber.scheduler
(package private) final Scheduler
FlowableThrottleFirstTimed.scheduler
(package private) final Scheduler
FlowableThrottleLatest.scheduler
(package private) final Scheduler
FlowableTimeInterval.scheduler
(package private) final Scheduler
FlowableTimeInterval.TimeIntervalSubscriber.scheduler
(package private) final Scheduler
FlowableTimeoutTimed.scheduler
(package private) final Scheduler
FlowableTimer.scheduler
(package private) final Scheduler
FlowableUnsubscribeOn.scheduler
(package private) final Scheduler
FlowableUnsubscribeOn.UnsubscribeSubscriber.scheduler
(package private) final Scheduler
FlowableWindowTimed.scheduler
(package private) final Scheduler
FlowableWindowTimed.WindowExactBoundedSubscriber.scheduler
(package private) final Scheduler
FlowableWindowTimed.WindowExactUnboundedSubscriber.scheduler
Methods in io.reactivex.rxjava3.internal.operators.flowable with parameters of type SchedulerModifier and TypeMethodDescriptionstatic <T> ConnectableFlowable
<T> FlowableReplay.create
(Flowable<T> source, long maxAge, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate) Creates a replaying ConnectableObservable with a time bound buffer.static <T> ConnectableFlowable
<T> FlowableReplay.create
(Flowable<T> source, long maxAge, TimeUnit unit, Scheduler scheduler, int bufferSize, boolean eagerTruncate) Creates a replaying ConnectableObservable with a size and time bound buffer.static <T> Supplier
<ConnectableFlowable<T>> FlowableInternalHelper.replaySupplier
(Flowable<T> parent, int bufferSize, long time, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate) static <T> Supplier
<ConnectableFlowable<T>> FlowableInternalHelper.replaySupplier
(Flowable<T> parent, long time, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate) Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type SchedulerModifierConstructorDescription(package private)
BufferedTimedReplay
(Flowable<T> parent, int bufferSize, long time, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate) (package private)
BufferExactUnboundedSubscriber
(org.reactivestreams.Subscriber<? super U> actual, Supplier<U> bufferSupplier, long timespan, TimeUnit unit, Scheduler scheduler) FlowableBufferTimed
(Flowable<T> source, long timespan, long timeskip, TimeUnit unit, Scheduler scheduler, Supplier<U> bufferSupplier, int maxSize, boolean restartTimerOnMaxSize) FlowableConcatMapScheduler
(Flowable<T> source, Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch, ErrorMode errorMode, Scheduler scheduler) FlowableDebounceTimed
(Flowable<T> source, long timeout, TimeUnit unit, Scheduler scheduler, Consumer<? super T> onDropped) FlowableDelay
(Flowable<T> source, long delay, TimeUnit unit, Scheduler scheduler, boolean delayError) FlowableInterval
(long initialDelay, long period, TimeUnit unit, Scheduler scheduler) FlowableIntervalRange
(long start, long end, long initialDelay, long period, TimeUnit unit, Scheduler scheduler) FlowableObserveOn
(Flowable<T> source, Scheduler scheduler, boolean delayError, int prefetch) FlowableRefCount
(ConnectableFlowable<T> source, int n, long timeout, TimeUnit unit, Scheduler scheduler) FlowableSampleTimed
(Flowable<T> source, long period, TimeUnit unit, Scheduler scheduler, boolean emitLast, Consumer<? super T> onDropped) FlowableSkipLastTimed
(Flowable<T> source, long time, TimeUnit unit, Scheduler scheduler, int bufferSize, boolean delayError) FlowableSubscribeOn
(Flowable<T> source, Scheduler scheduler, boolean nonScheduledRequests) FlowableTakeLastTimed
(Flowable<T> source, long count, long time, TimeUnit unit, Scheduler scheduler, int bufferSize, boolean delayError) FlowableThrottleFirstTimed
(Flowable<T> source, long timeout, TimeUnit unit, Scheduler scheduler, Consumer<? super T> onDropped) FlowableThrottleLatest
(Flowable<T> source, long timeout, TimeUnit unit, Scheduler scheduler, boolean emitLast, Consumer<? super T> onDropped) FlowableTimeInterval
(Flowable<T> source, TimeUnit unit, Scheduler scheduler) FlowableTimeoutTimed
(Flowable<T> source, long timeout, TimeUnit unit, Scheduler scheduler, org.reactivestreams.Publisher<? extends T> other) FlowableTimer
(long delay, TimeUnit unit, Scheduler scheduler) FlowableUnsubscribeOn
(Flowable<T> source, Scheduler scheduler) FlowableWindowTimed
(Flowable<T> source, long timespan, long timeskip, TimeUnit unit, Scheduler scheduler, long maxSize, int bufferSize, boolean restartTimerOnMaxSize) (package private)
SampleTimedEmitLast
(org.reactivestreams.Subscriber<? super T> actual, long period, TimeUnit unit, Scheduler scheduler, Consumer<? super T> onDropped) (package private)
SampleTimedNoLast
(org.reactivestreams.Subscriber<? super T> actual, long period, TimeUnit unit, Scheduler scheduler, Consumer<? super T> onDropped) (package private)
SampleTimedSubscriber
(org.reactivestreams.Subscriber<? super T> actual, long period, TimeUnit unit, Scheduler scheduler, Consumer<? super T> onDropped) (package private)
ScheduledReplayBufferSupplier
(int bufferSize, long maxAge, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate) (package private)
SizeAndTimeBoundReplayBuffer
(int limit, long maxAge, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate) (package private)
SkipLastTimedSubscriber
(org.reactivestreams.Subscriber<? super T> actual, long time, TimeUnit unit, Scheduler scheduler, int bufferSize, boolean delayError) (package private)
TakeLastTimedSubscriber
(org.reactivestreams.Subscriber<? super T> actual, long count, long time, TimeUnit unit, Scheduler scheduler, int bufferSize, boolean delayError) (package private)
TimedReplay
(Flowable<T> parent, long time, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate) (package private)
TimeIntervalSubscriber
(org.reactivestreams.Subscriber<? super Timed<T>> actual, TimeUnit unit, Scheduler scheduler) (package private)
UnsubscribeSubscriber
(org.reactivestreams.Subscriber<? super T> actual, Scheduler scheduler) (package private)
WindowExactBoundedSubscriber
(org.reactivestreams.Subscriber<? super Flowable<T>> actual, long timespan, TimeUnit unit, Scheduler scheduler, int bufferSize, long maxSize, boolean restartTimerOnMaxSize) (package private)
WindowExactUnboundedSubscriber
(org.reactivestreams.Subscriber<? super Flowable<T>> actual, long timespan, TimeUnit unit, Scheduler scheduler, int bufferSize) -
Uses of Scheduler in io.reactivex.rxjava3.internal.operators.maybe
Fields in io.reactivex.rxjava3.internal.operators.maybe declared as SchedulerModifier and TypeFieldDescription(package private) final Scheduler
MaybeDelay.DelayMaybeObserver.scheduler
(package private) final Scheduler
MaybeDelay.scheduler
(package private) final Scheduler
MaybeObserveOn.ObserveOnMaybeObserver.scheduler
(package private) final Scheduler
MaybeObserveOn.scheduler
(package private) final Scheduler
MaybeSubscribeOn.scheduler
(package private) final Scheduler
MaybeTimeInterval.scheduler
(package private) final Scheduler
MaybeTimeInterval.TimeIntervalMaybeObserver.scheduler
(package private) final Scheduler
MaybeTimer.scheduler
(package private) final Scheduler
MaybeUnsubscribeOn.scheduler
(package private) final Scheduler
MaybeUnsubscribeOn.UnsubscribeOnMaybeObserver.scheduler
Constructors in io.reactivex.rxjava3.internal.operators.maybe with parameters of type SchedulerModifierConstructorDescription(package private)
DelayMaybeObserver
(MaybeObserver<? super T> actual, long delay, TimeUnit unit, Scheduler scheduler, boolean delayError) MaybeDelay
(MaybeSource<T> source, long delay, TimeUnit unit, Scheduler scheduler, boolean delayError) MaybeObserveOn
(MaybeSource<T> source, Scheduler scheduler) MaybeSubscribeOn
(MaybeSource<T> source, Scheduler scheduler) MaybeTimeInterval
(MaybeSource<T> source, TimeUnit unit, Scheduler scheduler, boolean start) MaybeTimer
(long delay, TimeUnit unit, Scheduler scheduler) MaybeUnsubscribeOn
(MaybeSource<T> source, Scheduler scheduler) (package private)
ObserveOnMaybeObserver
(MaybeObserver<? super T> actual, Scheduler scheduler) (package private)
TimeIntervalMaybeObserver
(MaybeObserver<? super Timed<T>> downstream, TimeUnit unit, Scheduler scheduler, boolean start) (package private)
UnsubscribeOnMaybeObserver
(MaybeObserver<? super T> actual, Scheduler scheduler) -
Uses of Scheduler in io.reactivex.rxjava3.internal.operators.observable
Fields in io.reactivex.rxjava3.internal.operators.observable declared as SchedulerModifier and TypeFieldDescription(package private) final Scheduler
ObservableBufferTimed.BufferExactUnboundedObserver.scheduler
(package private) final Scheduler
ObservableBufferTimed.scheduler
(package private) final Scheduler
ObservableConcatMapScheduler.scheduler
(package private) final Scheduler
ObservableDebounceTimed.scheduler
(package private) final Scheduler
ObservableDelay.scheduler
(package private) final Scheduler
ObservableInternalHelper.BufferedTimedReplaySupplier.scheduler
(package private) final Scheduler
ObservableInternalHelper.TimedReplayCallable.scheduler
(package private) final Scheduler
ObservableInterval.scheduler
(package private) final Scheduler
ObservableIntervalRange.scheduler
(package private) final Scheduler
ObservableObserveOn.scheduler
(package private) final Scheduler
ObservableRefCount.scheduler
private final Scheduler
ObservableReplay.ScheduledReplaySupplier.scheduler
(package private) final Scheduler
ObservableReplay.SizeAndTimeBoundReplayBuffer.scheduler
(package private) final Scheduler
ObservableSampleTimed.SampleTimedObserver.scheduler
(package private) final Scheduler
ObservableSampleTimed.scheduler
(package private) final Scheduler
ObservableSkipLastTimed.scheduler
(package private) final Scheduler
ObservableSkipLastTimed.SkipLastTimedObserver.scheduler
(package private) final Scheduler
ObservableSubscribeOn.scheduler
(package private) final Scheduler
ObservableTakeLastTimed.scheduler
(package private) final Scheduler
ObservableTakeLastTimed.TakeLastTimedObserver.scheduler
(package private) final Scheduler
ObservableThrottleFirstTimed.scheduler
(package private) final Scheduler
ObservableThrottleLatest.scheduler
(package private) final Scheduler
ObservableTimeInterval.scheduler
(package private) final Scheduler
ObservableTimeInterval.TimeIntervalObserver.scheduler
(package private) final Scheduler
ObservableTimeoutTimed.scheduler
(package private) final Scheduler
ObservableTimer.scheduler
(package private) final Scheduler
ObservableUnsubscribeOn.scheduler
(package private) final Scheduler
ObservableUnsubscribeOn.UnsubscribeObserver.scheduler
(package private) final Scheduler
ObservableWindowTimed.scheduler
(package private) final Scheduler
ObservableWindowTimed.WindowExactBoundedObserver.scheduler
(package private) final Scheduler
ObservableWindowTimed.WindowExactUnboundedObserver.scheduler
Methods in io.reactivex.rxjava3.internal.operators.observable with parameters of type SchedulerModifier and TypeMethodDescriptionstatic <T> ConnectableObservable
<T> ObservableReplay.create
(ObservableSource<T> source, long maxAge, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate) Creates a replaying ConnectableObservable with a time bound buffer.static <T> ConnectableObservable
<T> ObservableReplay.create
(ObservableSource<T> source, long maxAge, TimeUnit unit, Scheduler scheduler, int bufferSize, boolean eagerTruncate) Creates a replaying ConnectableObservable with a size and time bound buffer.static <T> Supplier
<ConnectableObservable<T>> ObservableInternalHelper.replaySupplier
(Observable<T> parent, int bufferSize, long time, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate) static <T> Supplier
<ConnectableObservable<T>> ObservableInternalHelper.replaySupplier
(Observable<T> parent, long time, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate) Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type SchedulerModifierConstructorDescription(package private)
BufferedTimedReplaySupplier
(Observable<T> parent, int bufferSize, long time, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate) (package private)
BufferExactUnboundedObserver
(Observer<? super U> actual, Supplier<U> bufferSupplier, long timespan, TimeUnit unit, Scheduler scheduler) ObservableBufferTimed
(ObservableSource<T> source, long timespan, long timeskip, TimeUnit unit, Scheduler scheduler, Supplier<U> bufferSupplier, int maxSize, boolean restartTimerOnMaxSize) ObservableConcatMapScheduler
(ObservableSource<T> source, Function<? super T, ? extends ObservableSource<? extends U>> mapper, int bufferSize, ErrorMode delayErrors, Scheduler scheduler) ObservableDebounceTimed
(ObservableSource<T> source, long timeout, TimeUnit unit, Scheduler scheduler, Consumer<? super T> onDropped) ObservableDelay
(ObservableSource<T> source, long delay, TimeUnit unit, Scheduler scheduler, boolean delayError) ObservableInterval
(long initialDelay, long period, TimeUnit unit, Scheduler scheduler) ObservableIntervalRange
(long start, long end, long initialDelay, long period, TimeUnit unit, Scheduler scheduler) ObservableObserveOn
(ObservableSource<T> source, Scheduler scheduler, boolean delayError, int bufferSize) ObservableRefCount
(ConnectableObservable<T> source, int n, long timeout, TimeUnit unit, Scheduler scheduler) ObservableSampleTimed
(ObservableSource<T> source, long period, TimeUnit unit, Scheduler scheduler, boolean emitLast, Consumer<? super T> onDropped) ObservableSkipLastTimed
(ObservableSource<T> source, long time, TimeUnit unit, Scheduler scheduler, int bufferSize, boolean delayError) ObservableSubscribeOn
(ObservableSource<T> source, Scheduler scheduler) ObservableTakeLastTimed
(ObservableSource<T> source, long count, long time, TimeUnit unit, Scheduler scheduler, int bufferSize, boolean delayError) ObservableThrottleFirstTimed
(ObservableSource<T> source, long timeout, TimeUnit unit, Scheduler scheduler, Consumer<? super T> onDropped) ObservableThrottleLatest
(Observable<T> source, long timeout, TimeUnit unit, Scheduler scheduler, boolean emitLast, Consumer<? super T> onDropped) ObservableTimeInterval
(ObservableSource<T> source, TimeUnit unit, Scheduler scheduler) ObservableTimeoutTimed
(Observable<T> source, long timeout, TimeUnit unit, Scheduler scheduler, ObservableSource<? extends T> other) ObservableTimer
(long delay, TimeUnit unit, Scheduler scheduler) ObservableUnsubscribeOn
(ObservableSource<T> source, Scheduler scheduler) ObservableWindowTimed
(Observable<T> source, long timespan, long timeskip, TimeUnit unit, Scheduler scheduler, long maxSize, int bufferSize, boolean restartTimerOnMaxSize) (package private)
SampleTimedEmitLast
(Observer<? super T> actual, long period, TimeUnit unit, Scheduler scheduler, Consumer<? super T> onDropped) (package private)
SampleTimedNoLast
(Observer<? super T> actual, long period, TimeUnit unit, Scheduler scheduler, Consumer<? super T> onDropped) (package private)
SampleTimedObserver
(Observer<? super T> actual, long period, TimeUnit unit, Scheduler scheduler, Consumer<? super T> onDropped) (package private)
ScheduledReplaySupplier
(int bufferSize, long maxAge, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate) (package private)
SizeAndTimeBoundReplayBuffer
(int limit, long maxAge, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate) (package private)
SkipLastTimedObserver
(Observer<? super T> actual, long time, TimeUnit unit, Scheduler scheduler, int bufferSize, boolean delayError) (package private)
TakeLastTimedObserver
(Observer<? super T> actual, long count, long time, TimeUnit unit, Scheduler scheduler, int bufferSize, boolean delayError) (package private)
TimedReplayCallable
(Observable<T> parent, long time, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate) (package private)
(package private)
UnsubscribeObserver
(Observer<? super T> actual, Scheduler scheduler) (package private)
WindowExactBoundedObserver
(Observer<? super Observable<T>> actual, long timespan, TimeUnit unit, Scheduler scheduler, int bufferSize, long maxSize, boolean restartTimerOnMaxSize) (package private)
WindowExactUnboundedObserver
(Observer<? super Observable<T>> actual, long timespan, TimeUnit unit, Scheduler scheduler, int bufferSize) -
Uses of Scheduler in io.reactivex.rxjava3.internal.operators.parallel
Fields in io.reactivex.rxjava3.internal.operators.parallel declared as SchedulerConstructors in io.reactivex.rxjava3.internal.operators.parallel with parameters of type SchedulerModifierConstructorDescriptionParallelRunOn
(ParallelFlowable<? extends T> parent, Scheduler scheduler, int prefetch) -
Uses of Scheduler in io.reactivex.rxjava3.internal.operators.single
Fields in io.reactivex.rxjava3.internal.operators.single declared as SchedulerModifier and TypeFieldDescription(package private) final Scheduler
SingleDelay.scheduler
(package private) final Scheduler
SingleObserveOn.ObserveOnSingleObserver.scheduler
(package private) final Scheduler
SingleObserveOn.scheduler
(package private) final Scheduler
SingleSubscribeOn.scheduler
(package private) final Scheduler
SingleTimeInterval.scheduler
(package private) final Scheduler
SingleTimeInterval.TimeIntervalSingleObserver.scheduler
(package private) final Scheduler
SingleTimeout.scheduler
(package private) final Scheduler
SingleTimer.scheduler
(package private) final Scheduler
SingleUnsubscribeOn.scheduler
(package private) final Scheduler
SingleUnsubscribeOn.UnsubscribeOnSingleObserver.scheduler
Constructors in io.reactivex.rxjava3.internal.operators.single with parameters of type SchedulerModifierConstructorDescription(package private)
ObserveOnSingleObserver
(SingleObserver<? super T> actual, Scheduler scheduler) SingleDelay
(SingleSource<? extends T> source, long time, TimeUnit unit, Scheduler scheduler, boolean delayError) SingleObserveOn
(SingleSource<T> source, Scheduler scheduler) SingleSubscribeOn
(SingleSource<? extends T> source, Scheduler scheduler) SingleTimeInterval
(SingleSource<T> source, TimeUnit unit, Scheduler scheduler, boolean start) SingleTimeout
(SingleSource<T> source, long timeout, TimeUnit unit, Scheduler scheduler, SingleSource<? extends T> other) SingleTimer
(long delay, TimeUnit unit, Scheduler scheduler) SingleUnsubscribeOn
(SingleSource<T> source, Scheduler scheduler) (package private)
TimeIntervalSingleObserver
(SingleObserver<? super Timed<T>> downstream, TimeUnit unit, Scheduler scheduler, boolean start) (package private)
UnsubscribeOnSingleObserver
(SingleObserver<? super T> actual, Scheduler scheduler) -
Uses of Scheduler in io.reactivex.rxjava3.internal.schedulers
Subclasses of Scheduler in io.reactivex.rxjava3.internal.schedulersModifier and TypeClassDescriptionfinal class
Holds a fixed pool of worker threads and assigns them to requested Scheduler.Workers in a round-robin fashion.final class
Wraps an Executor and provides the Scheduler API over it.final class
A Scheduler partially implementing the API by allowing only non-delayed, non-periodic task execution on the current thread immediately.final class
Scheduler that creates and caches a set of thread pools and reuses them if possible.final class
Schedules work on a new thread.class
Allows the use of operators for controlling the timing around when actions scheduled on workers are actually done.final class
A scheduler with a shared, single threaded underlying ScheduledExecutorService.final class
Schedules work on the current thread but does not execute immediately.Fields in io.reactivex.rxjava3.internal.schedulers declared as SchedulerModifier and TypeFieldDescriptionprivate final Scheduler
SchedulerWhen.actualScheduler
(package private) static final Scheduler
ExecutorScheduler.SingleHolder.HELPER
static final Scheduler
ImmediateThinScheduler.INSTANCE
The singleton instance of the immediate (thin) scheduler.Constructors in io.reactivex.rxjava3.internal.schedulers with parameters of type SchedulerModifierConstructorDescriptionSchedulerWhen
(Function<Flowable<Flowable<Completable>>, Completable> combine, Scheduler actualScheduler) -
Uses of Scheduler in io.reactivex.rxjava3.observables
Methods in io.reactivex.rxjava3.observables with parameters of type SchedulerModifier and TypeMethodDescriptionfinal @NonNull Observable
<T> ConnectableObservable.refCount
(int observerCount, long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Connects to the upstreamConnectableObservable
if the number of subscribed observers reaches the specified count and disconnect after the specified timeout if allObserver
s have unsubscribed.final @NonNull Observable
<T> Connects to the upstreamConnectableObservable
if the number of subscribed observers reaches 1 and disconnect after the specified timeout if allObserver
s have unsubscribed. -
Uses of Scheduler in io.reactivex.rxjava3.parallel
Methods in io.reactivex.rxjava3.parallel with parameters of type SchedulerModifier and TypeMethodDescriptionfinal @NonNull ParallelFlowable
<T> Specifies where each 'rail' will observe its incoming values, specified via aScheduler
, with no work-stealing and default prefetch amount.final @NonNull ParallelFlowable
<T> Specifies where each 'rail' will observe its incoming values, specified via aScheduler
, with possibly work-stealing and a given prefetch amount. -
Uses of Scheduler in io.reactivex.rxjava3.plugins
Fields in io.reactivex.rxjava3.plugins with type parameters of type SchedulerModifier and TypeFieldDescriptionRxJavaPlugins.onComputationHandler
RxJavaPlugins.onComputationHandler
RxJavaPlugins.onInitComputationHandler
RxJavaPlugins.onInitComputationHandler
RxJavaPlugins.onInitIoHandler
RxJavaPlugins.onInitIoHandler
RxJavaPlugins.onInitNewThreadHandler
RxJavaPlugins.onInitNewThreadHandler
RxJavaPlugins.onInitSingleHandler
RxJavaPlugins.onInitSingleHandler
RxJavaPlugins.onIoHandler
RxJavaPlugins.onIoHandler
RxJavaPlugins.onNewThreadHandler
RxJavaPlugins.onNewThreadHandler
RxJavaPlugins.onSingleHandler
RxJavaPlugins.onSingleHandler
Methods in io.reactivex.rxjava3.plugins that return SchedulerModifier and TypeMethodDescriptionRxJavaPlugins.applyRequireNonNull
(@NonNull Function<? super Supplier<Scheduler>, ? extends Scheduler> f, Supplier<Scheduler> s) Wraps the call to the Scheduler creation function in try-catch and propagates thrown checked exceptions as RuntimeException and enforces that result is not null.RxJavaPlugins.callRequireNonNull
(@NonNull Supplier<Scheduler> s) Wraps the call to the Scheduler creation supplier in try-catch and propagates thrown checked exceptions as RuntimeException and enforces that result is not null.RxJavaPlugins.createComputationScheduler
(@NonNull ThreadFactory threadFactory) Create an instance of the defaultScheduler
used forSchedulers.computation()
except usingthreadFactory
for thread creation.RxJavaPlugins.createExecutorScheduler
(@NonNull Executor executor, boolean interruptibleWorker, boolean fair) RxJavaPlugins.createIoScheduler
(@NonNull ThreadFactory threadFactory) Create an instance of the defaultScheduler
used forSchedulers.io()
except usingthreadFactory
for thread creation.RxJavaPlugins.createNewThreadScheduler
(@NonNull ThreadFactory threadFactory) Create an instance of the defaultScheduler
used forSchedulers.newThread()
except usingthreadFactory
for thread creation.RxJavaPlugins.createSingleScheduler
(@NonNull ThreadFactory threadFactory) Create an instance of the defaultScheduler
used forSchedulers.single()
except usingthreadFactory
for thread creation.RxJavaPlugins.initComputationScheduler
(@NonNull Supplier<Scheduler> defaultScheduler) Calls the associated hook function.RxJavaPlugins.initIoScheduler
(@NonNull Supplier<Scheduler> defaultScheduler) Calls the associated hook function.RxJavaPlugins.initNewThreadScheduler
(@NonNull Supplier<Scheduler> defaultScheduler) Calls the associated hook function.RxJavaPlugins.initSingleScheduler
(@NonNull Supplier<Scheduler> defaultScheduler) Calls the associated hook function.RxJavaPlugins.onComputationScheduler
(@NonNull Scheduler defaultScheduler) Calls the associated hook function.RxJavaPlugins.onIoScheduler
(@NonNull Scheduler defaultScheduler) Calls the associated hook function.RxJavaPlugins.onNewThreadScheduler
(@NonNull Scheduler defaultScheduler) Calls the associated hook function.RxJavaPlugins.onSingleScheduler
(@NonNull Scheduler defaultScheduler) Calls the associated hook function.Methods in io.reactivex.rxjava3.plugins that return types with arguments of type SchedulerModifier and TypeMethodDescriptionRxJavaPlugins.getComputationSchedulerHandler()
Returns the current hook function.RxJavaPlugins.getComputationSchedulerHandler()
Returns the current hook function.RxJavaPlugins.getInitComputationSchedulerHandler()
Returns the current hook function.RxJavaPlugins.getInitComputationSchedulerHandler()
Returns the current hook function.RxJavaPlugins.getInitIoSchedulerHandler()
Returns the current hook function.RxJavaPlugins.getInitIoSchedulerHandler()
Returns the current hook function.RxJavaPlugins.getInitNewThreadSchedulerHandler()
Returns the current hook function.RxJavaPlugins.getInitNewThreadSchedulerHandler()
Returns the current hook function.RxJavaPlugins.getInitSingleSchedulerHandler()
Returns the current hook function.RxJavaPlugins.getInitSingleSchedulerHandler()
Returns the current hook function.RxJavaPlugins.getIoSchedulerHandler()
Returns the current hook function.RxJavaPlugins.getIoSchedulerHandler()
Returns the current hook function.RxJavaPlugins.getNewThreadSchedulerHandler()
Returns the current hook function.RxJavaPlugins.getNewThreadSchedulerHandler()
Returns the current hook function.RxJavaPlugins.getSingleSchedulerHandler()
Returns the current hook function.RxJavaPlugins.getSingleSchedulerHandler()
Returns the current hook function.Methods in io.reactivex.rxjava3.plugins with parameters of type SchedulerModifier and TypeMethodDescriptionRxJavaPlugins.onComputationScheduler
(@NonNull Scheduler defaultScheduler) Calls the associated hook function.RxJavaPlugins.onIoScheduler
(@NonNull Scheduler defaultScheduler) Calls the associated hook function.RxJavaPlugins.onNewThreadScheduler
(@NonNull Scheduler defaultScheduler) Calls the associated hook function.RxJavaPlugins.onSingleScheduler
(@NonNull Scheduler defaultScheduler) Calls the associated hook function.Method parameters in io.reactivex.rxjava3.plugins with type arguments of type SchedulerModifier and TypeMethodDescriptionRxJavaPlugins.applyRequireNonNull
(@NonNull Function<? super Supplier<Scheduler>, ? extends Scheduler> f, Supplier<Scheduler> s) Wraps the call to the Scheduler creation function in try-catch and propagates thrown checked exceptions as RuntimeException and enforces that result is not null.RxJavaPlugins.applyRequireNonNull
(@NonNull Function<? super Supplier<Scheduler>, ? extends Scheduler> f, Supplier<Scheduler> s) Wraps the call to the Scheduler creation function in try-catch and propagates thrown checked exceptions as RuntimeException and enforces that result is not null.RxJavaPlugins.applyRequireNonNull
(@NonNull Function<? super Supplier<Scheduler>, ? extends Scheduler> f, Supplier<Scheduler> s) Wraps the call to the Scheduler creation function in try-catch and propagates thrown checked exceptions as RuntimeException and enforces that result is not null.RxJavaPlugins.callRequireNonNull
(@NonNull Supplier<Scheduler> s) Wraps the call to the Scheduler creation supplier in try-catch and propagates thrown checked exceptions as RuntimeException and enforces that result is not null.RxJavaPlugins.initComputationScheduler
(@NonNull Supplier<Scheduler> defaultScheduler) Calls the associated hook function.RxJavaPlugins.initIoScheduler
(@NonNull Supplier<Scheduler> defaultScheduler) Calls the associated hook function.RxJavaPlugins.initNewThreadScheduler
(@NonNull Supplier<Scheduler> defaultScheduler) Calls the associated hook function.RxJavaPlugins.initSingleScheduler
(@NonNull Supplier<Scheduler> defaultScheduler) Calls the associated hook function.static void
RxJavaPlugins.setComputationSchedulerHandler
(@Nullable Function<? super Scheduler, ? extends Scheduler> handler) Sets the specific hook function.static void
RxJavaPlugins.setComputationSchedulerHandler
(@Nullable Function<? super Scheduler, ? extends Scheduler> handler) Sets the specific hook function.static void
RxJavaPlugins.setInitComputationSchedulerHandler
(@Nullable Function<? super Supplier<Scheduler>, ? extends Scheduler> handler) Sets the specific hook function.static void
RxJavaPlugins.setInitComputationSchedulerHandler
(@Nullable Function<? super Supplier<Scheduler>, ? extends Scheduler> handler) Sets the specific hook function.static void
RxJavaPlugins.setInitIoSchedulerHandler
(@Nullable Function<? super Supplier<Scheduler>, ? extends Scheduler> handler) Sets the specific hook function.static void
RxJavaPlugins.setInitIoSchedulerHandler
(@Nullable Function<? super Supplier<Scheduler>, ? extends Scheduler> handler) Sets the specific hook function.static void
RxJavaPlugins.setInitNewThreadSchedulerHandler
(@Nullable Function<? super Supplier<Scheduler>, ? extends Scheduler> handler) Sets the specific hook function.static void
RxJavaPlugins.setInitNewThreadSchedulerHandler
(@Nullable Function<? super Supplier<Scheduler>, ? extends Scheduler> handler) Sets the specific hook function.static void
RxJavaPlugins.setInitSingleSchedulerHandler
(@Nullable Function<? super Supplier<Scheduler>, ? extends Scheduler> handler) Sets the specific hook function.static void
RxJavaPlugins.setInitSingleSchedulerHandler
(@Nullable Function<? super Supplier<Scheduler>, ? extends Scheduler> handler) Sets the specific hook function.static void
RxJavaPlugins.setIoSchedulerHandler
(@Nullable Function<? super Scheduler, ? extends Scheduler> handler) Sets the specific hook function.static void
RxJavaPlugins.setIoSchedulerHandler
(@Nullable Function<? super Scheduler, ? extends Scheduler> handler) Sets the specific hook function.static void
RxJavaPlugins.setNewThreadSchedulerHandler
(@Nullable Function<? super Scheduler, ? extends Scheduler> handler) Sets the specific hook function.static void
RxJavaPlugins.setNewThreadSchedulerHandler
(@Nullable Function<? super Scheduler, ? extends Scheduler> handler) Sets the specific hook function.static void
RxJavaPlugins.setSingleSchedulerHandler
(@Nullable Function<? super Scheduler, ? extends Scheduler> handler) Sets the specific hook function.static void
RxJavaPlugins.setSingleSchedulerHandler
(@Nullable Function<? super Scheduler, ? extends Scheduler> handler) Sets the specific hook function. -
Uses of Scheduler in io.reactivex.rxjava3.processors
Fields in io.reactivex.rxjava3.processors declared as SchedulerModifier and TypeFieldDescription(package private) final Scheduler
ReplayProcessor.SizeAndTimeBoundReplayBuffer.scheduler
Methods in io.reactivex.rxjava3.processors with parameters of type SchedulerModifier and TypeMethodDescriptionstatic <T> @NonNull ReplayProcessor
<T> ReplayProcessor.createWithTime
(long maxAge, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Creates a time-bounded ReplayProcessor.static <T> @NonNull ReplayProcessor
<T> ReplayProcessor.createWithTimeAndSize
(long maxAge, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, int maxSize) Creates a time- and size-bounded ReplayProcessor.Constructors in io.reactivex.rxjava3.processors with parameters of type SchedulerModifierConstructorDescription(package private)
SizeAndTimeBoundReplayBuffer
(int maxSize, long maxAge, TimeUnit unit, Scheduler scheduler) -
Uses of Scheduler in io.reactivex.rxjava3.schedulers
Subclasses of Scheduler in io.reactivex.rxjava3.schedulersModifier and TypeClassDescriptionfinal class
A special, non thread-safe scheduler for testing operators that require a scheduler without introducing real concurrency and allows manually advancing a virtual time.Fields in io.reactivex.rxjava3.schedulers declared as SchedulerModifier and TypeFieldDescriptionSchedulers.COMPUTATION
(package private) static final Scheduler
Schedulers.ComputationHolder.DEFAULT
(package private) static final Scheduler
Schedulers.IoHolder.DEFAULT
(package private) static final Scheduler
Schedulers.NewThreadHolder.DEFAULT
(package private) static final Scheduler
Schedulers.SingleHolder.DEFAULT
Schedulers.IO
Schedulers.NEW_THREAD
Schedulers.SINGLE
Schedulers.TRAMPOLINE
Methods in io.reactivex.rxjava3.schedulers that return SchedulerModifier and TypeMethodDescriptionSchedulers.computation()
Returns a default, sharedScheduler
instance intended for computational work.Schedulers.ComputationTask.get()
Schedulers.IOTask.get()
Schedulers.NewThreadTask.get()
Schedulers.SingleTask.get()
Schedulers.io()
Returns a default, sharedScheduler
instance intended for IO-bound work.Schedulers.newThread()
Schedulers.single()
Returns a default, shared, single-thread-backedScheduler
instance for work requiring strongly-sequential execution on the same background thread.Schedulers.trampoline()
Returns a default, sharedScheduler
instance whoseScheduler.Worker
instances queue work and execute them in a FIFO manner on one of the participating threads. -
Uses of Scheduler in io.reactivex.rxjava3.subjects
Fields in io.reactivex.rxjava3.subjects declared as SchedulerModifier and TypeFieldDescription(package private) final Scheduler
ReplaySubject.SizeAndTimeBoundReplayBuffer.scheduler
Methods in io.reactivex.rxjava3.subjects with parameters of type SchedulerModifier and TypeMethodDescriptionstatic <T> @NonNull ReplaySubject
<T> ReplaySubject.createWithTime
(long maxAge, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Creates a time-bounded replay subject.static <T> @NonNull ReplaySubject
<T> ReplaySubject.createWithTimeAndSize
(long maxAge, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, int maxSize) Creates a time- and size-bounded replay subject.Constructors in io.reactivex.rxjava3.subjects with parameters of type SchedulerModifierConstructorDescription(package private)
SizeAndTimeBoundReplayBuffer
(int maxSize, long maxAge, TimeUnit unit, Scheduler scheduler)