Uses of Class
io.reactivex.rxjava3.core.Observable
Packages that use Observable
Package
Description
Base reactive classes:
Flowable
, Observable
,
Single
, Maybe
and
Completable
; base reactive consumers;
other common base interfaces.Base interfaces and types for supporting operator-fusion.
Classes supporting the Observable base reactive class:
ConnectableObservable
and
GroupedObservable
.Contains the central plugin handler
RxJavaPlugins
class to hook into the lifecycle of the base reactive types and schedulers.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 Observable in io.reactivex.rxjava3.core
Methods in io.reactivex.rxjava3.core that return ObservableModifier and TypeMethodDescriptionstatic <@NonNull T>
@NonNull Observable<T> Observable.amb
(@NonNull Iterable<@NonNull ? extends ObservableSource<? extends @NonNull T>> sources) Mirrors the oneObservableSource
in anIterable
of severalObservableSource
s that first either emits an item or sends a termination notification.static <@NonNull T>
@NonNull Observable<T> Observable.ambArray
(@NonNull ObservableSource<? extends @NonNull T>... sources) Mirrors the oneObservableSource
in an array of severalObservableSource
s that first either emits an item or sends a termination notification.final @NonNull Observable
<T> Observable.ambWith
(@NonNull ObservableSource<? extends @NonNull T> other) Mirrors the currentObservable
or the otherObservableSource
provided of which the first either emits an item or sends a termination notification.final <@NonNull T>
@NonNull Observable<T> Completable.andThen
(@NonNull ObservableSource<@NonNull T> next) Returns anObservable
which will subscribe to thisCompletable
and once that is completed then will subscribe to thenext
ObservableSource
.final @NonNull Observable
<@NonNull List<T>> Observable.buffer
(int count) Returns anObservable
that emits buffers of items it collects from the currentObservable
.final @NonNull Observable
<@NonNull List<T>> Observable.buffer
(int count, int skip) Returns anObservable
that emits buffers of items it collects from the currentObservable
.final <@NonNull U extends Collection<? super @NonNull T>>
@NonNull Observable<U> Returns anObservable
that emits buffers of items it collects from the currentObservable
.final <@NonNull U extends Collection<? super @NonNull T>>
@NonNull Observable<U> 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>> 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 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
.Observable.buffer
(@NonNull ObservableSource<? extends @NonNull TOpening> openingIndicator, @NonNull Function<? super @NonNull TOpening, ? extends ObservableSource<? extends @NonNull TClosing>> closingIndicator) Returns anObservable
that emits buffers of items it collects from the currentObservable
.final <@NonNull TOpening,
@NonNull TClosing, @NonNull U extends Collection<? super @NonNull T>>
@NonNull Observable<U> Observable.buffer
(@NonNull ObservableSource<? extends @NonNull TOpening> openingIndicator, @NonNull Function<? super @NonNull TOpening, ? extends ObservableSource<? extends @NonNull TClosing>> closingIndicator, @NonNull Supplier<@NonNull U> bufferSupplier) Returns anObservable
that emits buffers of items it collects from the currentObservable
.Observable.buffer
(@NonNull ObservableSource<@NonNull B> boundaryIndicator) Returns anObservable
that emits non-overlapping buffered items from the currentObservable
each time the specified boundaryObservableSource
emits an item.Observable.buffer
(@NonNull ObservableSource<@NonNull B> boundaryIndicator, int initialCapacity) Returns anObservable
that emits non-overlapping buffered items from the currentObservable
each time the specified boundaryObservableSource
emits an item.final <@NonNull B,
@NonNull U extends Collection<? super @NonNull T>>
@NonNull Observable<U> Observable.buffer
(@NonNull ObservableSource<@NonNull B> boundaryIndicator, @NonNull Supplier<@NonNull U> bufferSupplier) Returns anObservable
that emits non-overlapping buffered items from the currentObservable
each time the specified boundaryObservableSource
emits an item.final @NonNull Observable
<T> Observable.cache()
Returns anObservable
that subscribes to the currentObservable
lazily, caches all of its events and replays them, in the same order as received, to all the downstream observers.final @NonNull Observable
<T> Observable.cacheWithInitialCapacity
(int initialCapacity) Returns anObservable
that subscribes to the currentObservable
lazily, caches all of its events and replays them, in the same order as received, to all the downstream observers.final <@NonNull U>
@NonNull Observable<U> Returns anObservable
that emits the upstream items while they can be cast viaClass.cast(Object)
until the upstream terminates, or until the upstream signals an item which can't be cast, resulting in aClassCastException
to be signaled to the downstream.static <@NonNull T1,
@NonNull T2, @NonNull T3, @NonNull T4, @NonNull T5, @NonNull T6, @NonNull T7, @NonNull T8, @NonNull T9, @NonNull R>
@NonNull Observable<R> Observable.combineLatest
(@NonNull ObservableSource<? extends @NonNull T1> source1, @NonNull ObservableSource<? extends @NonNull T2> source2, @NonNull ObservableSource<? extends @NonNull T3> source3, @NonNull ObservableSource<? extends @NonNull T4> source4, @NonNull ObservableSource<? extends @NonNull T5> source5, @NonNull ObservableSource<? extends @NonNull T6> source6, @NonNull ObservableSource<? extends @NonNull T7> source7, @NonNull ObservableSource<? extends @NonNull T8> source8, @NonNull ObservableSource<? extends @NonNull T9> source9, @NonNull Function9<? super @NonNull T1, ? super @NonNull T2, ? super @NonNull T3, ? super @NonNull T4, ? super @NonNull T5, ? super @NonNull T6, ? super @NonNull T7, ? super @NonNull T8, ? super @NonNull T9, ? extends @NonNull R> combiner) Combines nine sourceObservableSource
s by emitting an item that aggregates the latest values of each of theObservableSource
s each time an item is received from any of theObservableSource
s, where this aggregation is defined by a specified function.static <@NonNull T1,
@NonNull T2, @NonNull T3, @NonNull T4, @NonNull T5, @NonNull T6, @NonNull T7, @NonNull T8, @NonNull R>
@NonNull Observable<R> Observable.combineLatest
(@NonNull ObservableSource<? extends @NonNull T1> source1, @NonNull ObservableSource<? extends @NonNull T2> source2, @NonNull ObservableSource<? extends @NonNull T3> source3, @NonNull ObservableSource<? extends @NonNull T4> source4, @NonNull ObservableSource<? extends @NonNull T5> source5, @NonNull ObservableSource<? extends @NonNull T6> source6, @NonNull ObservableSource<? extends @NonNull T7> source7, @NonNull ObservableSource<? extends @NonNull T8> source8, @NonNull Function8<? super @NonNull T1, ? super @NonNull T2, ? super @NonNull T3, ? super @NonNull T4, ? super @NonNull T5, ? super @NonNull T6, ? super @NonNull T7, ? super @NonNull T8, ? extends @NonNull R> combiner) Combines eight sourceObservableSource
s by emitting an item that aggregates the latest values of each of theObservableSource
s each time an item is received from any of theObservableSource
s, where this aggregation is defined by a specified function.static <@NonNull T1,
@NonNull T2, @NonNull T3, @NonNull T4, @NonNull T5, @NonNull T6, @NonNull T7, @NonNull R>
@NonNull Observable<R> Observable.combineLatest
(@NonNull ObservableSource<? extends @NonNull T1> source1, @NonNull ObservableSource<? extends @NonNull T2> source2, @NonNull ObservableSource<? extends @NonNull T3> source3, @NonNull ObservableSource<? extends @NonNull T4> source4, @NonNull ObservableSource<? extends @NonNull T5> source5, @NonNull ObservableSource<? extends @NonNull T6> source6, @NonNull ObservableSource<? extends @NonNull T7> source7, @NonNull Function7<? super @NonNull T1, ? super @NonNull T2, ? super @NonNull T3, ? super @NonNull T4, ? super @NonNull T5, ? super @NonNull T6, ? super @NonNull T7, ? extends @NonNull R> combiner) Combines seven sourceObservableSource
s by emitting an item that aggregates the latest values of each of theObservableSource
s each time an item is received from any of theObservableSource
s, where this aggregation is defined by a specified function.static <@NonNull T1,
@NonNull T2, @NonNull T3, @NonNull T4, @NonNull T5, @NonNull T6, @NonNull R>
@NonNull Observable<R> Observable.combineLatest
(@NonNull ObservableSource<? extends @NonNull T1> source1, @NonNull ObservableSource<? extends @NonNull T2> source2, @NonNull ObservableSource<? extends @NonNull T3> source3, @NonNull ObservableSource<? extends @NonNull T4> source4, @NonNull ObservableSource<? extends @NonNull T5> source5, @NonNull ObservableSource<? extends @NonNull T6> source6, @NonNull Function6<? super @NonNull T1, ? super @NonNull T2, ? super @NonNull T3, ? super @NonNull T4, ? super @NonNull T5, ? super @NonNull T6, ? extends @NonNull R> combiner) Combines six sourceObservableSource
s by emitting an item that aggregates the latest values of each of theObservableSource
s each time an item is received from any of theObservableSource
s, where this aggregation is defined by a specified function.static <@NonNull T1,
@NonNull T2, @NonNull T3, @NonNull T4, @NonNull T5, @NonNull R>
@NonNull Observable<R> Observable.combineLatest
(@NonNull ObservableSource<? extends @NonNull T1> source1, @NonNull ObservableSource<? extends @NonNull T2> source2, @NonNull ObservableSource<? extends @NonNull T3> source3, @NonNull ObservableSource<? extends @NonNull T4> source4, @NonNull ObservableSource<? extends @NonNull T5> source5, @NonNull Function5<? super @NonNull T1, ? super @NonNull T2, ? super @NonNull T3, ? super @NonNull T4, ? super @NonNull T5, ? extends @NonNull R> combiner) Combines five sourceObservableSource
s by emitting an item that aggregates the latest values of each of theObservableSource
s each time an item is received from any of theObservableSource
s, where this aggregation is defined by a specified function.Observable.combineLatest
(@NonNull ObservableSource<? extends @NonNull T1> source1, @NonNull ObservableSource<? extends @NonNull T2> source2, @NonNull ObservableSource<? extends @NonNull T3> source3, @NonNull ObservableSource<? extends @NonNull T4> source4, @NonNull Function4<? super @NonNull T1, ? super @NonNull T2, ? super @NonNull T3, ? super @NonNull T4, ? extends @NonNull R> combiner) Combines four sourceObservableSource
s by emitting an item that aggregates the latest values of each of theObservableSource
s each time an item is received from any of theObservableSource
s, where this aggregation is defined by a specified function.Observable.combineLatest
(@NonNull ObservableSource<? extends @NonNull T1> source1, @NonNull ObservableSource<? extends @NonNull T2> source2, @NonNull ObservableSource<? extends @NonNull T3> source3, @NonNull Function3<? super @NonNull T1, ? super @NonNull T2, ? super @NonNull T3, ? extends @NonNull R> combiner) Combines three sourceObservableSource
s by emitting an item that aggregates the latest values of each of theObservableSource
s each time an item is received from any of theObservableSource
s, where this aggregation is defined by a specified function.static <@NonNull T1,
@NonNull T2, @NonNull R>
@NonNull Observable<R> Observable.combineLatest
(@NonNull ObservableSource<? extends @NonNull T1> source1, @NonNull ObservableSource<? extends @NonNull T2> source2, @NonNull BiFunction<? super @NonNull T1, ? super @NonNull T2, ? extends @NonNull R> combiner) Combines two sourceObservableSource
s by emitting an item that aggregates the latest values of each of theObservableSource
s each time an item is received from either of theObservableSource
s, where this aggregation is defined by a specified function.static <@NonNull T,
@NonNull R>
@NonNull Observable<R> Observable.combineLatest
(@NonNull Iterable<@NonNull ? extends ObservableSource<? extends @NonNull T>> sources, @NonNull Function<? super Object[], ? extends @NonNull R> combiner) Combines a collection of sourceObservableSource
s by emitting an item that aggregates the latest values of each of the returnedObservableSource
s each time an item is received from any of the returnedObservableSource
s, where this aggregation is defined by a specified function.static <@NonNull T,
@NonNull R>
@NonNull Observable<R> Observable.combineLatest
(@NonNull Iterable<@NonNull ? extends ObservableSource<? extends @NonNull T>> sources, @NonNull Function<? super Object[], ? extends @NonNull R> combiner, int bufferSize) Combines anIterable
of sourceObservableSource
s by emitting an item that aggregates the latest values of each of the returnedObservableSource
s each time an item is received from any of the returnedObservableSource
s, where this aggregation is defined by a specified function.static <@NonNull T,
@NonNull R>
@NonNull Observable<R> Observable.combineLatestArray
(@NonNull ObservableSource<? extends @NonNull T>[] sources, @NonNull Function<? super Object[], ? extends @NonNull R> combiner) Combines an array of sourceObservableSource
s by emitting an item that aggregates the latest values of each of theObservableSource
s each time an item is received from any of the returnedObservableSource
s, where this aggregation is defined by a specified function.static <@NonNull T,
@NonNull R>
@NonNull Observable<R> Observable.combineLatestArray
(@NonNull ObservableSource<? extends @NonNull T>[] sources, @NonNull Function<? super Object[], ? extends @NonNull R> combiner, int bufferSize) Combines an array of sourceObservableSource
s by emitting an item that aggregates the latest values of each of theObservableSource
s each time an item is received from any of theObservableSource
s, where this aggregation is defined by a specified function.static <@NonNull T,
@NonNull R>
@NonNull Observable<R> Observable.combineLatestArrayDelayError
(@NonNull ObservableSource<? extends @NonNull T>[] sources, @NonNull Function<? super Object[], ? extends @NonNull R> combiner) Combines an array ofObservableSource
s by emitting an item that aggregates the latest values of each of theObservableSource
s each time an item is received from any of theObservableSource
s, where this aggregation is defined by a specified function.static <@NonNull T,
@NonNull R>
@NonNull Observable<R> Observable.combineLatestArrayDelayError
(@NonNull ObservableSource<? extends @NonNull T>[] sources, @NonNull Function<? super Object[], ? extends @NonNull R> combiner, int bufferSize) Combines an array ofObservableSource
s by emitting an item that aggregates the latest values of each of theObservableSource
s each time an item is received from any of theObservableSource
s, where this aggregation is defined by a specified function and delays any error from the sources until all sourceObservableSource
s terminate.static <@NonNull T,
@NonNull R>
@NonNull Observable<R> Observable.combineLatestDelayError
(@NonNull Iterable<@NonNull ? extends ObservableSource<? extends @NonNull T>> sources, @NonNull Function<? super Object[], ? extends @NonNull R> combiner) Combines anIterable
ofObservableSource
s by emitting an item that aggregates the latest values of each of theObservableSource
s each time an item is received from any of theObservableSource
s, where this aggregation is defined by a specified function and delays any error from the sources until all sourceObservableSource
s terminate.static <@NonNull T,
@NonNull R>
@NonNull Observable<R> Observable.combineLatestDelayError
(@NonNull Iterable<@NonNull ? extends ObservableSource<? extends @NonNull T>> sources, @NonNull Function<? super Object[], ? extends @NonNull R> combiner, int bufferSize) Combines anIterable
ofObservableSource
s by emitting an item that aggregates the latest values of each of theObservableSource
s each time an item is received from any of theObservableSource
s, where this aggregation is defined by a specified function and delays any error from the sources until all sourceObservableSource
s terminate.final <@NonNull R>
@NonNull Observable<R> Observable.compose
(@NonNull ObservableTransformer<? super @NonNull T, ? extends @NonNull R> composer) Transform the currentObservable
by applying a particularObservableTransformer
function to it.static <@NonNull T>
@NonNull Observable<T> Observable.concat
(@NonNull ObservableSource<? extends ObservableSource<? extends @NonNull T>> sources) Returns anObservable
that emits the items emitted by each of theObservableSource
s emitted by theObservableSource
, one after the other, without interleaving them.static <@NonNull T>
@NonNull Observable<T> Observable.concat
(@NonNull ObservableSource<? extends ObservableSource<? extends @NonNull T>> sources, int bufferSize) Returns anObservable
that emits the items emitted by each of theObservableSource
s emitted by the outerObservableSource
, one after the other, without interleaving them.static <@NonNull T>
@NonNull Observable<T> Observable.concat
(@NonNull ObservableSource<? extends @NonNull T> source1, @NonNull ObservableSource<? extends @NonNull T> source2, @NonNull ObservableSource<? extends @NonNull T> source3) Returns anObservable
that emits the items emitted by threeObservableSource
s, one after the other, without interleaving them.static <@NonNull T>
@NonNull Observable<T> Observable.concat
(@NonNull ObservableSource<? extends @NonNull T> source1, @NonNull ObservableSource<? extends @NonNull T> source2, @NonNull ObservableSource<? extends @NonNull T> source3, @NonNull ObservableSource<? extends @NonNull T> source4) Returns anObservable
that emits the items emitted by fourObservableSource
s, one after the other, without interleaving them.static <@NonNull T>
@NonNull Observable<T> Observable.concat
(@NonNull ObservableSource<? extends @NonNull T> source1, ObservableSource<? extends @NonNull T> source2) Returns anObservable
that emits the items emitted by twoObservableSource
s, one after the other, without interleaving them.static <@NonNull T>
@NonNull Observable<T> Observable.concat
(@NonNull Iterable<@NonNull ? extends ObservableSource<? extends @NonNull T>> sources) Concatenates elements of eachObservableSource
provided via anIterable
sequence into a single sequence of elements without interleaving them.static <@NonNull T>
@NonNull Observable<T> Single.concat
(@NonNull ObservableSource<? extends SingleSource<? extends @NonNull T>> sources) Concatenate the single values, in a non-overlapping fashion, of theSingleSource
s provided by anObservableSource
sequence.static <@NonNull T>
@NonNull Observable<T> Observable.concatArray
(@NonNull ObservableSource<? extends @NonNull T>... sources) Concatenates a variable number ofObservableSource
sources.static <@NonNull T>
@NonNull Observable<T> Observable.concatArrayDelayError
(@NonNull ObservableSource<? extends @NonNull T>... sources) Concatenates a variable number ofObservableSource
sources and delays errors from any of them till all terminate.static <@NonNull T>
@NonNull Observable<T> Observable.concatArrayEager
(int maxConcurrency, int bufferSize, @NonNull ObservableSource<? extends @NonNull T>... sources) Concatenates an array ofObservableSource
s eagerly into a single stream of values.static <@NonNull T>
@NonNull Observable<T> Observable.concatArrayEager
(@NonNull ObservableSource<? extends @NonNull T>... sources) Concatenates an array ofObservableSource
s eagerly into a single stream of values.static <@NonNull T>
@NonNull Observable<T> Observable.concatArrayEagerDelayError
(int maxConcurrency, int bufferSize, @NonNull ObservableSource<? extends @NonNull T>... sources) Concatenates an array ofObservableSource
s eagerly into a single stream of values and delaying any errors until all sources terminate.static <@NonNull T>
@NonNull Observable<T> Observable.concatArrayEagerDelayError
(@NonNull ObservableSource<? extends @NonNull T>... sources) Concatenates an array ofObservableSource
s eagerly into a single stream of values and delaying any errors until all sources terminate.static <@NonNull T>
@NonNull Observable<T> Observable.concatDelayError
(@NonNull ObservableSource<? extends ObservableSource<? extends @NonNull T>> sources) Concatenates theObservableSource
sequence ofObservableSource
s into a singleObservable
sequence by subscribing to each innerObservableSource
, one after the other, one at a time and delays any errors till the all inner and the outerObservableSource
s terminate.static <@NonNull T>
@NonNull Observable<T> Observable.concatDelayError
(@NonNull ObservableSource<? extends ObservableSource<? extends @NonNull T>> sources, int bufferSize, boolean tillTheEnd) Concatenates theObservableSource
sequence ofObservableSource
s into a single sequence by subscribing to each innerObservableSource
, one after the other, one at a time and delays any errors till the all inner and the outerObservableSource
s terminate.static <@NonNull T>
@NonNull Observable<T> Observable.concatDelayError
(@NonNull Iterable<@NonNull ? extends ObservableSource<? extends @NonNull T>> sources) Concatenates theIterable
sequence ofObservableSource
s into a singleObservable
sequence by subscribing to eachObservableSource
, one after the other, one at a time and delays any errors till the all innerObservableSource
s terminate.static <@NonNull T>
@NonNull Observable<T> Observable.concatEager
(@NonNull ObservableSource<? extends ObservableSource<? extends @NonNull T>> sources) Concatenates anObservableSource
sequence ofObservableSource
s eagerly into a single stream of values.static <@NonNull T>
@NonNull Observable<T> Observable.concatEager
(@NonNull ObservableSource<? extends ObservableSource<? extends @NonNull T>> sources, int maxConcurrency, int bufferSize) Concatenates anObservableSource
sequence ofObservableSource
s eagerly into a single stream of values and runs a limited number of inner sequences at once.static <@NonNull T>
@NonNull Observable<T> Observable.concatEager
(@NonNull Iterable<@NonNull ? extends ObservableSource<? extends @NonNull T>> sources) Concatenates a sequence ofObservableSource
s eagerly into a single stream of values.static <@NonNull T>
@NonNull Observable<T> Observable.concatEager
(@NonNull Iterable<@NonNull ? extends ObservableSource<? extends @NonNull T>> sources, int maxConcurrency, int bufferSize) Concatenates a sequence ofObservableSource
s eagerly into a single stream of values and runs a limited number of inner sequences at once.static <@NonNull T>
@NonNull Observable<T> Observable.concatEagerDelayError
(@NonNull ObservableSource<? extends ObservableSource<? extends @NonNull T>> sources) Concatenates anObservableSource
sequence ofObservableSource
s eagerly into a single stream of values, delaying errors until all the inner and the outer sequence terminate.static <@NonNull T>
@NonNull Observable<T> Observable.concatEagerDelayError
(@NonNull ObservableSource<? extends ObservableSource<? extends @NonNull T>> sources, int maxConcurrency, int bufferSize) Concatenates anObservableSource
sequence ofObservableSource
s eagerly into a single stream of values, delaying errors until all the inner and the outer sequence terminate and runs a limited number of inner sequences at once.static <@NonNull T>
@NonNull Observable<T> Observable.concatEagerDelayError
(@NonNull Iterable<@NonNull ? extends ObservableSource<? extends @NonNull T>> sources) Concatenates a sequence ofObservableSource
s eagerly into a single stream of values, delaying errors until all the inner sequences terminate.static <@NonNull T>
@NonNull Observable<T> Observable.concatEagerDelayError
(@NonNull Iterable<@NonNull ? extends ObservableSource<? extends @NonNull T>> sources, int maxConcurrency, int bufferSize) Concatenates a sequence ofObservableSource
s eagerly into a single stream of values, delaying errors until all the inner sequences terminate and runs a limited number of inner sequences at once.final <@NonNull R>
@NonNull Observable<R> Observable.concatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper) 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.final <@NonNull R>
@NonNull Observable<R> Observable.concatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper, int bufferSize) 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.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.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapDelayError
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper) 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.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapDelayError
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper, boolean tillTheEnd, int bufferSize) 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.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.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapEager
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper) Maps a sequence of values intoObservableSource
s and concatenates theseObservableSource
s eagerly into a singleObservable
sequence.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapEager
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper, int maxConcurrency, int bufferSize) Maps a sequence of values intoObservableSource
s and concatenates theseObservableSource
s eagerly into a singleObservable
sequence.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapEagerDelayError
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper, boolean tillTheEnd) Maps a sequence of values intoObservableSource
s and concatenates theseObservableSource
s eagerly into a singleObservable
sequence.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapEagerDelayError
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper, boolean tillTheEnd, int maxConcurrency, int bufferSize) Maps a sequence of values intoObservableSource
s and concatenates theseObservableSource
s eagerly into a singleObservable
sequence.final <@NonNull U>
@NonNull Observable<U> Observable.concatMapIterable
(@NonNull Function<? super @NonNull T, @NonNull ? extends Iterable<? extends @NonNull U>> mapper) Returns anObservable
that concatenate each item emitted by the currentObservable
with the values in anIterable
corresponding to that item that is generated by a selector.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapMaybe
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Maps the upstream items intoMaybeSource
s and subscribes to them one after the other succeeds or completes, emits their success value if available or terminates immediately if either the currentObservable
or the current innerMaybeSource
fail.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapMaybe
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper, int bufferSize) Maps the upstream items intoMaybeSource
s and subscribes to them one after the other succeeds or completes, emits their success value if available or terminates immediately if either the currentObservable
or the current innerMaybeSource
fail.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapMaybeDelayError
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Maps the upstream items intoMaybeSource
s and subscribes to them one after the other terminates, emits their success value if available and delaying all errors till both the currentObservable
and all innerMaybeSource
s terminate.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapMaybeDelayError
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper, boolean tillTheEnd) Maps the upstream items intoMaybeSource
s and subscribes to them one after the other terminates, emits their success value if available and optionally delaying all errors till both the currentObservable
and all innerMaybeSource
s terminate.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapMaybeDelayError
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper, boolean tillTheEnd, int bufferSize) Maps the upstream items intoMaybeSource
s and subscribes to them one after the other terminates, emits their success value if available and optionally delaying all errors till both the currentObservable
and all innerMaybeSource
s terminate.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapSingle
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper) Maps the upstream items intoSingleSource
s and subscribes to them one after the other succeeds, emits their success values or terminates immediately if either the currentObservable
or the current innerSingleSource
fail.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapSingle
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper, int bufferSize) Maps the upstream items intoSingleSource
s and subscribes to them one after the other succeeds, emits their success values or terminates immediately if either the currentObservable
or the current innerSingleSource
fail.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapSingleDelayError
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper) Maps the upstream items intoSingleSource
s and subscribes to them one after the other succeeds or fails, emits their success values and delays all errors till both the currentObservable
and all innerSingleSource
s terminate.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapSingleDelayError
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper, boolean tillTheEnd) Maps the upstream items intoSingleSource
s and subscribes to them one after the other succeeds or fails, emits their success values and optionally delays all errors till both the currentObservable
and all innerSingleSource
s terminate.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapSingleDelayError
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper, boolean tillTheEnd, int bufferSize) Maps the upstream items intoSingleSource
s and subscribes to them one after the other succeeds or fails, emits their success values and optionally delays errors till both the currentObservable
and all innerSingleSource
s terminate.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapStream
(@NonNull Function<? super @NonNull T, @NonNull ? extends Stream<? extends @NonNull R>> mapper) Maps each upstream item into aStream
and emits theStream
's items to the downstream in a sequential fashion.final @NonNull Observable
<T> Observable.concatWith
(@NonNull CompletableSource other) Returns anObservable
that emits items from the currentObservable
and when it completes normally, the otherCompletableSource
is subscribed to and the returnedObservable
emits its terminal events.final @NonNull Observable
<T> Observable.concatWith
(@NonNull MaybeSource<? extends @NonNull T> other) Returns anObservable
that emits the items from the currentObservable
followed by the success item or terminal events of the otherMaybeSource
.final @NonNull Observable
<T> Observable.concatWith
(@NonNull ObservableSource<? extends @NonNull T> other) Returns anObservable
that first emits the items emitted from the currentObservable
, then items from theother
ObservableSource
without interleaving them.final @NonNull Observable
<T> Observable.concatWith
(@NonNull SingleSource<? extends @NonNull T> other) Returns anObservable
that emits the items from the currentObservable
followed by the success item or error event of theother
SingleSource
.static <@NonNull T>
@NonNull Observable<T> Observable.create
(@NonNull ObservableOnSubscribe<@NonNull T> source) Provides an API (via a coldObservable
) that bridges the reactive world with the callback-style world.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.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 U>
@NonNull Observable<T> Observable.debounce
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<@NonNull U>> debounceIndicator) Returns anObservable
that mirrors the currentObservable
, except that it drops items emitted by the currentObservable
that are followed by another item within a computed debounce duration denoted by an item emission or completion from a generated innerObservableSource
for that original item.final @NonNull Observable
<T> Observable.defaultIfEmpty
(@NonNull T defaultItem) Returns anObservable
that emits the items emitted by the currentObservable
or a specified default item if the currentObservable
is empty.static <@NonNull T>
@NonNull Observable<T> Observable.defer
(@NonNull Supplier<? extends @NonNull ObservableSource<? extends @NonNull T>> supplier) Returns anObservable
that calls anObservableSource
factory to create anObservableSource
for each newObserver
that subscribes.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> Returns anObservable
that emits the items emitted by the currentObservable
shifted forward in time by a specified delay.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.final <@NonNull U,
@NonNull V>
@NonNull Observable<T> Observable.delay
(@NonNull ObservableSource<@NonNull U> subscriptionIndicator, @NonNull Function<? super @NonNull T, ? extends ObservableSource<@NonNull V>> itemDelayIndicator) Returns anObservable
that delays the subscription to and emissions from the currentObservable
viaObservableSource
s for the subscription itself and on a per-item basis.final <@NonNull U>
@NonNull Observable<T> Observable.delay
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<@NonNull U>> itemDelayIndicator) Returns anObservable
that delays the emissions of the currentObservable
via a per-item derivedObservableSource
's item emission or termination, on a per source item basis.final @NonNull Observable
<T> Observable.delaySubscription
(long time, @NonNull TimeUnit unit) Returns anObservable
that delays the subscription to the currentObservable
by a given amount of time.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
.final <@NonNull U>
@NonNull Observable<T> Observable.delaySubscription
(@NonNull ObservableSource<@NonNull U> subscriptionIndicator) Returns anObservable
that delays the subscription to the currentObservable
until the otherObservableSource
emits an element or completes normally.final <@NonNull R>
@NonNull Observable<R> Observable.dematerialize
(@NonNull Function<? super @NonNull T, Notification<@NonNull R>> selector) Returns anObservable
that reverses the effect ofmaterialize
by transforming theNotification
objects extracted from the source items via a selector function into their respectiveObserver
signal types.final @NonNull Observable
<T> Observable.distinct()
Returns anObservable
that emits all items emitted by the currentObservable
that are distinct based onObject.equals(Object)
comparison.final <@NonNull K>
@NonNull Observable<T> Returns anObservable
that emits all items emitted by the currentObservable
that are distinct according to a key selector function and based onObject.equals(Object)
comparison of the objects returned by the key selector function.final <@NonNull K>
@NonNull Observable<T> Observable.distinct
(@NonNull Function<? super @NonNull T, @NonNull K> keySelector, @NonNull Supplier<? extends Collection<? super @NonNull K>> collectionSupplier) Returns anObservable
that emits all items emitted by the currentObservable
that are distinct according to a key selector function and based onObject.equals(Object)
comparison of the objects returned by the key selector function.final @NonNull Observable
<T> Observable.distinctUntilChanged()
Returns anObservable
that emits all items emitted by the currentObservable
that are distinct from their immediate predecessors based onObject.equals(Object)
comparison.final @NonNull Observable
<T> Observable.distinctUntilChanged
(@NonNull BiPredicate<? super @NonNull T, ? super @NonNull T> comparer) Returns anObservable
that emits all items emitted by the currentObservable
that are distinct from their immediate predecessors when compared with each other via the provided comparator function.final <@NonNull K>
@NonNull Observable<T> Returns anObservable
that emits all items emitted by the currentObservable
that are distinct from their immediate predecessors, according to a key selector function and based onObject.equals(Object)
comparison of those objects returned by the key selector function.final @NonNull Observable
<T> Observable.doAfterNext
(@NonNull Consumer<? super @NonNull T> onAfterNext) Calls the specifiedConsumer
with the current item after this item has been emitted to the downstream.final @NonNull Observable
<T> Observable.doAfterTerminate
(@NonNull Action onAfterTerminate) final @NonNull Observable
<T> Calls the specified action after the currentObservable
signalsonError
oronCompleted
or gets disposed by the downstream.final @NonNull Observable
<T> Observable.doOnComplete
(@NonNull Action onComplete) final @NonNull Observable
<T> Observable.doOnDispose
(@NonNull Action onDispose) Calls the given sharedAction
if the downstream disposes the sequence.final @NonNull Observable
<T> Returns anObservable
that forwards the items and terminal events of the currentObservable
to itsObserver
s and to the given sharedObserver
instance.final @NonNull Observable
<T> Returns anObservable
that invokes aConsumer
with the appropriateNotification
object when the currentObservable
signals an item or terminates.private @NonNull Observable
<T> Observable.doOnEach
(@NonNull Consumer<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError, @NonNull Action onComplete, @NonNull Action onAfterTerminate) Calls the appropriateonXXX
consumer (shared between allObserver
s) whenever a signal with the same type passes through, before forwarding them to the downstream.final @NonNull Observable
<T> final @NonNull Observable
<T> Observable.doOnLifecycle
(@NonNull Consumer<? super Disposable> onSubscribe, @NonNull Action onDispose) Calls the appropriateonXXX
method (shared between allObserver
s) for the lifecycle events of the sequence (subscription, disposal).final @NonNull Observable
<T> Calls the givenConsumer
with the value emitted by the currentObservable
before forwarding it to the downstream.final @NonNull Observable
<T> Observable.doOnSubscribe
(@NonNull Consumer<? super Disposable> onSubscribe) final @NonNull Observable
<T> Observable.doOnTerminate
(@NonNull Action onTerminate) Returns anObservable
so that it invokes an action when the currentObservable
callsonComplete
oronError
.static <@NonNull T>
@NonNull Observable<T> Observable.empty()
Returns anObservable
that emits no items to theObserver
and immediately invokes itsonComplete
method.static <@NonNull T>
@NonNull Observable<T> static <@NonNull T>
@NonNull Observable<T> final @NonNull Observable
<T> Filters items emitted by the currentObservable
by only emitting those that satisfy a specifiedPredicate
.final <@NonNull R>
@NonNull Observable<R> Observable.flatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper) Returns anObservable
that emits items based on applying a function that you supply to each item emitted by the currentObservable
, where that function returns anObservableSource
, and then merging those returnedObservableSource
s and emitting the results of this merger.final <@NonNull R>
@NonNull Observable<R> Observable.flatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper, boolean delayErrors) Returns anObservable
that emits items based on applying a function that you supply to each item emitted by the currentObservable
, where that function returns anObservableSource
, and then merging those returnedObservableSource
s and emitting the results of this merger.final <@NonNull R>
@NonNull Observable<R> Observable.flatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper, boolean delayErrors, int maxConcurrency) Returns anObservable
that emits items based on applying a function that you supply to each item emitted by the currentObservable
, where that function returns anObservableSource
, and then merging those returnedObservableSource
s and emitting the results of this merger, while limiting the maximum number of concurrent subscriptions to theseObservableSource
s.final <@NonNull R>
@NonNull Observable<R> Observable.flatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper, boolean delayErrors, int maxConcurrency, int bufferSize) Returns anObservable
that emits items based on applying a function that you supply to each item emitted by the currentObservable
, where that function returns anObservableSource
, and then merging those returnedObservableSource
s and emitting the results of this merger, while limiting the maximum number of concurrent subscriptions to theseObservableSource
s.final <@NonNull R>
@NonNull Observable<R> Observable.flatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper, int maxConcurrency) Returns anObservable
that emits items based on applying a function that you supply to each item emitted by the currentObservable
, where that function returns anObservableSource
, and then merging those returnedObservableSource
s and emitting the results of this merger, while limiting the maximum number of concurrent subscriptions to theseObservableSource
s.final <@NonNull R>
@NonNull Observable<R> Observable.flatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> onNextMapper, @NonNull Function<? super Throwable, ? extends ObservableSource<? extends @NonNull R>> onErrorMapper, @NonNull Supplier<? extends ObservableSource<? extends @NonNull R>> onCompleteSupplier) Returns anObservable
that applies a function to each item emitted or notification raised by the currentObservable
and then flattens theObservableSource
s returned from these functions and emits the resulting items.final <@NonNull R>
@NonNull Observable<R> Observable.flatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> onNextMapper, @NonNull Function<Throwable, ? extends ObservableSource<? extends @NonNull R>> onErrorMapper, @NonNull Supplier<? extends ObservableSource<? extends @NonNull R>> onCompleteSupplier, int maxConcurrency) Returns anObservable
that applies a function to each item emitted or notification raised by the currentObservable
and then flattens theObservableSource
s returned from these functions and emits the resulting items, while limiting the maximum number of concurrent subscriptions to theseObservableSource
s.final <@NonNull U,
@NonNull R>
@NonNull Observable<R> Observable.flatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull U>> mapper, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> combiner) Returns anObservable
that emits the results of a specified function to the pair of values emitted by the currentObservable
and the mapped innerObservableSource
.final <@NonNull U,
@NonNull R>
@NonNull Observable<R> Observable.flatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull U>> mapper, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> combiner, boolean delayErrors) Returns anObservable
that emits the results of a specified function to the pair of values emitted by the currentObservable
and the mapped innerObservableSource
.final <@NonNull U,
@NonNull R>
@NonNull Observable<R> Observable.flatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull U>> mapper, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> combiner, boolean delayErrors, int maxConcurrency) Returns anObservable
that emits the results of a specified function to the pair of values emitted by the currentObservable
and the mapped innerObservableSource
, while limiting the maximum number of concurrent subscriptions to theseObservableSource
s.final <@NonNull U,
@NonNull R>
@NonNull Observable<R> Observable.flatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull U>> mapper, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> combiner, boolean delayErrors, int maxConcurrency, int bufferSize) Returns anObservable
that emits the results of a specified function to the pair of values emitted by the currentObservable
and the mapped innerObservableSource
, while limiting the maximum number of concurrent subscriptions to theseObservableSource
s.final <@NonNull U,
@NonNull R>
@NonNull Observable<R> Observable.flatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull U>> mapper, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> combiner, int maxConcurrency) Returns anObservable
that emits the results of a specified function to the pair of values emitted by the currentObservable
and the mapped innerObservableSource
, while limiting the maximum number of concurrent subscriptions to theseObservableSource
s.final <@NonNull U>
@NonNull Observable<U> Observable.flatMapIterable
(@NonNull Function<? super @NonNull T, @NonNull ? extends Iterable<? extends @NonNull U>> mapper) final <@NonNull U,
@NonNull V>
@NonNull Observable<V> Observable.flatMapIterable
(@NonNull Function<? super @NonNull T, @NonNull ? extends Iterable<? extends @NonNull U>> mapper, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull V> combiner) MergesIterable
s generated by a mapperFunction
for each individual item emitted by the currentObservable
into a singleObservable
sequence where the resulting items will be the combination of the original item and each inner item of the respectiveIterable
as returned by theresultSelector
BiFunction
.final <@NonNull R>
@NonNull Observable<R> Observable.flatMapMaybe
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Maps each element of the currentObservable
intoMaybeSource
s, subscribes to all of them and merges theironSuccess
values, in no particular order, into a singleObservable
sequence.final <@NonNull R>
@NonNull Observable<R> Observable.flatMapMaybe
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper, boolean delayErrors) Maps each element of the currentObservable
intoMaybeSource
s, subscribes to them and merges theironSuccess
values, in no particular order, into a singleObservable
sequence, optionally delaying all errors.final <@NonNull R>
@NonNull Observable<R> Maybe.flatMapObservable
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper) Returns anObservable
that is based on applying a specified function to the item emitted by the currentMaybe
, where that function returns anObservableSource
.final <@NonNull R>
@NonNull Observable<R> Single.flatMapObservable
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper) Returns anObservable
that is based on applying a specified function to the item emitted by the currentSingle
, where that function returns anObservableSource
.final <@NonNull R>
@NonNull Observable<R> Observable.flatMapSingle
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper) Maps each element of the currentObservable
intoSingleSource
s, subscribes to all of them and merges theironSuccess
values, in no particular order, into a singleObservable
sequence.final <@NonNull R>
@NonNull Observable<R> Observable.flatMapSingle
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper, boolean delayErrors) Maps each element of the currentObservable
intoSingleSource
s, subscribes to them and merges theironSuccess
values, in no particular order, into a singleObservable
sequence, optionally delaying all errors.final <@NonNull R>
@NonNull Observable<R> Observable.flatMapStream
(@NonNull Function<? super @NonNull T, @NonNull ? extends Stream<? extends @NonNull R>> mapper) Maps each upstream item into aStream
and emits theStream
's items to the downstream in a sequential fashion.final <@NonNull U>
@NonNull Observable<U> Maybe.flattenAsObservable
(@NonNull Function<? super @NonNull T, @NonNull ? extends Iterable<? extends @NonNull U>> mapper) Maps the success value of the currentMaybe
into anIterable
and emits its items as anObservable
sequence.final <@NonNull U>
@NonNull Observable<U> Single.flattenAsObservable
(@NonNull Function<@NonNull ? super @NonNull T, @NonNull ? extends Iterable<? extends @NonNull U>> mapper) Maps the success value of the currentSingle
into anIterable
and emits its items as anObservable
sequence.final <@NonNull R>
@NonNull Observable<R> Maybe.flattenStreamAsObservable
(@NonNull Function<? super @NonNull T, @NonNull ? extends Stream<? extends @NonNull R>> mapper) Maps the upstream succecss value into a JavaStream
and emits its items to the downstream consumer as anObservable
.final <@NonNull R>
@NonNull Observable<R> Single.flattenStreamAsObservable
(@NonNull Function<? super @NonNull T, @NonNull ? extends Stream<? extends @NonNull R>> mapper) Maps the upstream succecss value into a JavaStream
and emits its items to the downstream consumer as anObservable
.static <@NonNull T>
@NonNull Observable<T> Observable.fromAction
(@NonNull Action action) static <@NonNull T>
@NonNull Observable<T> Converts an array into anObservableSource
that emits the items in the array.static <@NonNull T>
@NonNull Observable<T> Observable.fromCallable
(@NonNull Callable<? extends @NonNull T> callable) Returns anObservable
that, when an observer subscribes to it, invokes a function you specify and then emits the value returned from that function.static <@NonNull T>
@NonNull Observable<T> Observable.fromCompletable
(@NonNull CompletableSource completableSource) Wraps aCompletableSource
into anObservable
.static <@NonNull T>
@NonNull Observable<@NonNull T> Observable.fromCompletionStage
(@NonNull CompletionStage<@NonNull T> stage) Signals the completion value or error of the given (hot)CompletionStage
-based asynchronous calculation.static <@NonNull T>
@NonNull Observable<T> Observable.fromFuture
(@NonNull Future<? extends @NonNull T> future) Converts aFuture
into anObservable
.static <@NonNull T>
@NonNull Observable<T> Observable.fromFuture
(@NonNull Future<? extends @NonNull T> future, long timeout, @NonNull TimeUnit unit) static <@NonNull T>
@NonNull Observable<T> Observable.fromIterable
(@NonNull Iterable<? extends @NonNull T> source) Converts anIterable
sequence into anObservable
that emits the items in the sequence.static <@NonNull T>
@NonNull Observable<T> Observable.fromMaybe
(@NonNull MaybeSource<@NonNull T> maybe) Returns anObservable
instance that when subscribed to, subscribes to theMaybeSource
instance and emitsonSuccess
as a single item or forwards anyonComplete
oronError
signal.static <@NonNull T>
@NonNull Observable<@NonNull T> Observable.fromOptional
(@NonNull Optional<@NonNull T> optional) Converts the existing value of the provided optional into ajust(Object)
or an empty optional into anempty()
Observable
instance.static <@NonNull T>
@NonNull Observable<T> Observable.fromPublisher
(@NonNull org.reactivestreams.Publisher<? extends @NonNull T> publisher) Converts an arbitrary Reactive StreamsPublisher
into anObservable
.static <@NonNull T>
@NonNull Observable<T> Observable.fromRunnable
(@NonNull Runnable run) static <@NonNull T>
@NonNull Observable<T> Observable.fromSingle
(@NonNull SingleSource<@NonNull T> source) Returns anObservable
instance that when subscribed to, subscribes to theSingleSource
instance and emitsonSuccess
as a single item or forwards theonError
signal.static <@NonNull T>
@NonNull Observable<@NonNull T> Observable.fromStream
(@NonNull Stream<@NonNull T> stream) Converts aStream
into a finiteObservable
and emits its items in the sequence.static <@NonNull T>
@NonNull Observable<T> Observable.fromSupplier
(@NonNull Supplier<? extends @NonNull T> supplier) Returns anObservable
that, when an observer subscribes to it, invokes a supplier function you specify and then emits the value returned from that function.static <@NonNull T>
@NonNull Observable<T> Returns a cold, synchronous and stateless generator of values.static <@NonNull T,
@NonNull S>
@NonNull Observable<T> Observable.generate
(@NonNull Supplier<@NonNull S> initialState, @NonNull BiConsumer<@NonNull S, Emitter<@NonNull T>> generator) Returns a cold, synchronous and stateful generator of values.static <@NonNull T,
@NonNull S>
@NonNull Observable<T> Observable.generate
(@NonNull Supplier<@NonNull S> initialState, @NonNull BiConsumer<@NonNull S, Emitter<@NonNull T>> generator, @NonNull Consumer<? super @NonNull S> disposeState) Returns a cold, synchronous and stateful generator of values.static <@NonNull T,
@NonNull S>
@NonNull Observable<T> Observable.generate
(@NonNull Supplier<@NonNull S> initialState, @NonNull BiFunction<@NonNull S, Emitter<@NonNull T>, @NonNull S> generator) Returns a cold, synchronous and stateful generator of values.static <@NonNull T,
@NonNull S>
@NonNull Observable<T> Observable.generate
(@NonNull Supplier<@NonNull S> initialState, @NonNull BiFunction<@NonNull S, Emitter<@NonNull T>, @NonNull S> generator, @NonNull Consumer<? super @NonNull S> disposeState) Returns a cold, synchronous and stateful generator of values.final <@NonNull K>
@NonNull Observable<GroupedObservable<K, T>> Groups the items emitted by the currentObservable
according to a specified criterion, and emits these grouped items asGroupedObservable
s.final <@NonNull K>
@NonNull Observable<GroupedObservable<K, T>> Observable.groupBy
(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, boolean delayError) Groups the items emitted by the currentObservable
according to a specified criterion, and emits these grouped items asGroupedObservable
s.final <@NonNull K,
@NonNull V>
@NonNull Observable<GroupedObservable<K, V>> Observable.groupBy
(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, @NonNull Function<? super @NonNull T, ? extends @NonNull V> valueSelector, boolean delayError) Groups the items emitted by the currentObservable
according to a specified criterion, and emits these grouped items asGroupedObservable
s.final <@NonNull K,
@NonNull V>
@NonNull Observable<GroupedObservable<K, V>> Observable.groupBy
(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, @NonNull Function<? super @NonNull T, ? extends @NonNull V> valueSelector, boolean delayError, int bufferSize) Groups the items emitted by the currentObservable
according to a specified criterion, and emits these grouped items asGroupedObservable
s.final <@NonNull K,
@NonNull V>
@NonNull Observable<GroupedObservable<K, V>> Observable.groupBy
(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, Function<? super @NonNull T, ? extends @NonNull V> valueSelector) Groups the items emitted by the currentObservable
according to a specified criterion, and emits these grouped items asGroupedObservable
s.Observable.groupJoin
(@NonNull ObservableSource<? extends @NonNull TRight> other, @NonNull Function<? super @NonNull T, ? extends ObservableSource<@NonNull TLeftEnd>> leftEnd, @NonNull Function<? super @NonNull TRight, ? extends ObservableSource<@NonNull TRightEnd>> rightEnd, @NonNull BiFunction<? super @NonNull T, ? super Observable<@NonNull TRight>, ? extends @NonNull R> resultSelector) Returns anObservable
that correlates twoObservableSource
s when they overlap in time and groups the results.final @NonNull Observable
<T> Observable.hide()
Hides the identity of the currentObservable
and itsDisposable
.static @NonNull Observable
<Long> Returns anObservable
that emits a0L
after theinitialDelay
and ever increasing numbers after eachperiod
of time thereafter.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.static @NonNull Observable
<Long> Returns anObservable
that emits a sequential number every specified interval of time, on a specifiedScheduler
.static @NonNull Observable
<Long> Observable.intervalRange
(long start, long count, long initialDelay, long period, @NonNull TimeUnit unit) 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.Observable.join
(@NonNull ObservableSource<? extends @NonNull TRight> other, @NonNull Function<? super @NonNull T, ? extends ObservableSource<@NonNull TLeftEnd>> leftEnd, @NonNull Function<? super @NonNull TRight, ? extends ObservableSource<@NonNull TRightEnd>> rightEnd, @NonNull BiFunction<? super @NonNull T, ? super @NonNull TRight, ? extends @NonNull R> resultSelector) Correlates the items emitted by twoObservableSource
s based on overlapping durations.static <@NonNull T>
@NonNull Observable<T> Returns anObservable
that signals the given (constant reference) item and then completes.static <@NonNull T>
@NonNull Observable<T> Converts two items into anObservable
that emits those items.static <@NonNull T>
@NonNull Observable<T> Converts three items into anObservable
that emits those items.static <@NonNull T>
@NonNull Observable<T> Converts four items into anObservable
that emits those items.static <@NonNull T>
@NonNull Observable<T> Observable.just
(@NonNull T item1, @NonNull T item2, @NonNull T item3, @NonNull T item4, @NonNull T item5) Converts five items into anObservable
that emits those items.static <@NonNull T>
@NonNull Observable<T> Observable.just
(@NonNull T item1, @NonNull T item2, @NonNull T item3, @NonNull T item4, @NonNull T item5, @NonNull T item6) Converts six items into anObservable
that emits those items.static <@NonNull T>
@NonNull Observable<T> Observable.just
(@NonNull T item1, @NonNull T item2, @NonNull T item3, @NonNull T item4, @NonNull T item5, @NonNull T item6, @NonNull T item7) Converts seven items into anObservable
that emits those items.static <@NonNull T>
@NonNull Observable<T> Observable.just
(@NonNull T item1, @NonNull T item2, @NonNull T item3, @NonNull T item4, @NonNull T item5, @NonNull T item6, @NonNull T item7, @NonNull T item8) Converts eight items into anObservable
that emits those items.static <@NonNull T>
@NonNull Observable<T> Observable.just
(@NonNull T item1, @NonNull T item2, @NonNull T item3, @NonNull T item4, @NonNull T item5, @NonNull T item6, @NonNull T item7, @NonNull T item8, @NonNull T item9) Converts nine items into anObservable
that emits those items.static <@NonNull T>
@NonNull Observable<T> Observable.just
(@NonNull T item1, @NonNull T item2, @NonNull T item3, @NonNull T item4, @NonNull T item5, @NonNull T item6, @NonNull T item7, @NonNull T item8, @NonNull T item9, @NonNull T item10) Converts ten items into anObservable
that emits those items.final <@NonNull R>
@NonNull Observable<R> This method requires advanced knowledge about building operators, please consider other standard composition methods first; Returns anObservable
which, when subscribed to, invokes theapply(Observer)
method of the providedObservableOperator
for each individual downstreamObserver
and allows the insertion of a custom operator by accessing the downstream'sObserver
during this subscription phase and providing a newObserver
, containing the custom operator's intended business logic, that will be used in the subscription process going further upstream.final <@NonNull R>
@NonNull Observable<R> Returns anObservable
that applies a specified function to each item emitted by the currentObservable
and emits the results of these function applications.final <@NonNull R>
@NonNull Observable<R> Observable.mapOptional
(@NonNull Function<? super @NonNull T, @NonNull Optional<? extends @NonNull R>> mapper) Maps each upstream value into anOptional
and emits the contained item if not empty.final @NonNull Observable
<Notification<T>> Observable.materialize()
Returns anObservable
that represents all of the emissions and notifications from the currentObservable
into emissions marked with their original types withinNotification
objects.static <@NonNull T>
@NonNull Observable<T> Observable.merge
(@NonNull ObservableSource<? extends ObservableSource<? extends @NonNull T>> sources) Flattens anObservableSource
that emitsObservableSource
s into a singleObservable
that emits the items emitted by thoseObservableSource
s, without any transformation.static <@NonNull T>
@NonNull Observable<T> Observable.merge
(@NonNull ObservableSource<? extends ObservableSource<? extends @NonNull T>> sources, int maxConcurrency) Flattens anObservableSource
that emitsObservableSource
s into a singleObservable
that emits the items emitted by thoseObservableSource
s, without any transformation, while limiting the maximum number of concurrent subscriptions to theseObservableSource
s.static <@NonNull T>
@NonNull Observable<T> Observable.merge
(@NonNull ObservableSource<? extends @NonNull T> source1, @NonNull ObservableSource<? extends @NonNull T> source2) Flattens twoObservableSource
s into a singleObservable
, without any transformation.static <@NonNull T>
@NonNull Observable<T> Observable.merge
(@NonNull ObservableSource<? extends @NonNull T> source1, @NonNull ObservableSource<? extends @NonNull T> source2, @NonNull ObservableSource<? extends @NonNull T> source3) Flattens threeObservableSource
s into a singleObservable
, without any transformation.static <@NonNull T>
@NonNull Observable<T> Observable.merge
(@NonNull ObservableSource<? extends @NonNull T> source1, @NonNull ObservableSource<? extends @NonNull T> source2, @NonNull ObservableSource<? extends @NonNull T> source3, @NonNull ObservableSource<? extends @NonNull T> source4) Flattens fourObservableSource
s into a singleObservable
, without any transformation.static <@NonNull T>
@NonNull Observable<T> Observable.merge
(@NonNull Iterable<@NonNull ? extends ObservableSource<? extends @NonNull T>> sources) static <@NonNull T>
@NonNull Observable<T> Observable.merge
(@NonNull Iterable<@NonNull ? extends ObservableSource<? extends @NonNull T>> sources, int maxConcurrency) Flattens anIterable
ofObservableSource
s into oneObservable
, without any transformation, while limiting the number of concurrent subscriptions to theseObservableSource
s.static <@NonNull T>
@NonNull Observable<T> Observable.merge
(@NonNull Iterable<@NonNull ? extends ObservableSource<? extends @NonNull T>> sources, int maxConcurrency, int bufferSize) Flattens anIterable
ofObservableSource
s into oneObservable
, without any transformation, while limiting the number of concurrent subscriptions to theseObservableSource
s.static <@NonNull T>
@NonNull Observable<T> Observable.mergeArray
(int maxConcurrency, int bufferSize, @NonNull ObservableSource<? extends @NonNull T>... sources) Flattens an array ofObservableSource
s into oneObservable
, without any transformation, while limiting the number of concurrent subscriptions to theseObservableSource
s.static <@NonNull T>
@NonNull Observable<T> Observable.mergeArray
(@NonNull ObservableSource<? extends @NonNull T>... sources) Flattens an array ofObservableSource
s into oneObservable
, without any transformation.static <@NonNull T>
@NonNull Observable<T> Observable.mergeArrayDelayError
(int maxConcurrency, int bufferSize, @NonNull ObservableSource<? extends @NonNull T>... sources) Flattens an array ofObservableSource
s into oneObservable
, in a way that allows anObserver
to receive all successfully emitted items from each of theObservableSource
s without being interrupted by an error notification from one of them, while limiting the number of concurrent subscriptions to theseObservableSource
s.static <@NonNull T>
@NonNull Observable<T> Observable.mergeArrayDelayError
(@NonNull ObservableSource<? extends @NonNull T>... sources) Flattens an array ofObservableSource
s into oneObservable
, in a way that allows anObserver
to receive all successfully emitted items from each of theObservableSource
s without being interrupted by an error notification from one of them.static <@NonNull T>
@NonNull Observable<T> Observable.mergeDelayError
(@NonNull ObservableSource<? extends ObservableSource<? extends @NonNull T>> sources) Flattens anObservableSource
that emitsObservableSource
s into oneObservable
, in a way that allows anObserver
to receive all successfully emitted items from all of the emittedObservableSource
s without being interrupted by an error notification from one of them.static <@NonNull T>
@NonNull Observable<T> Observable.mergeDelayError
(@NonNull ObservableSource<? extends ObservableSource<? extends @NonNull T>> sources, int maxConcurrency) Flattens anObservableSource
that emitsObservableSource
s into oneObservable
, in a way that allows anObserver
to receive all successfully emitted items from all of the emittedObservableSource
s without being interrupted by an error notification from one of them, while limiting the number of concurrent subscriptions to theseObservableSource
s.static <@NonNull T>
@NonNull Observable<T> Observable.mergeDelayError
(@NonNull ObservableSource<? extends @NonNull T> source1, @NonNull ObservableSource<? extends @NonNull T> source2) Flattens twoObservableSource
s into oneObservable
, in a way that allows anObserver
to receive all successfully emitted items from each of theObservableSource
s without being interrupted by an error notification from one of them.static <@NonNull T>
@NonNull Observable<T> Observable.mergeDelayError
(@NonNull ObservableSource<? extends @NonNull T> source1, @NonNull ObservableSource<? extends @NonNull T> source2, @NonNull ObservableSource<? extends @NonNull T> source3) Flattens threeObservableSource
s into oneObservable
, in a way that allows anObserver
to receive all successfully emitted items from all of theObservableSource
s without being interrupted by an error notification from one of them.static <@NonNull T>
@NonNull Observable<T> Observable.mergeDelayError
(@NonNull ObservableSource<? extends @NonNull T> source1, @NonNull ObservableSource<? extends @NonNull T> source2, @NonNull ObservableSource<? extends @NonNull T> source3, @NonNull ObservableSource<? extends @NonNull T> source4) Flattens fourObservableSource
s into oneObservable
, in a way that allows anObserver
to receive all successfully emitted items from all of theObservableSource
s without being interrupted by an error notification from one of them.static <@NonNull T>
@NonNull Observable<T> Observable.mergeDelayError
(@NonNull Iterable<@NonNull ? extends ObservableSource<? extends @NonNull T>> sources) Flattens anIterable
ofObservableSource
s into oneObservable
, in a way that allows anObserver
to receive all successfully emitted items from each of the returnedObservableSource
s without being interrupted by an error notification from one of them.static <@NonNull T>
@NonNull Observable<T> Observable.mergeDelayError
(@NonNull Iterable<@NonNull ? extends ObservableSource<? extends @NonNull T>> sources, int maxConcurrency) Flattens anIterable
ofObservableSource
s into oneObservable
, in a way that allows anObserver
to receive all successfully emitted items from each of the returnedObservableSource
s without being interrupted by an error notification from one of them, while limiting the number of concurrent subscriptions to theseObservableSource
s.static <@NonNull T>
@NonNull Observable<T> Observable.mergeDelayError
(@NonNull Iterable<@NonNull ? extends ObservableSource<? extends @NonNull T>> sources, int maxConcurrency, int bufferSize) Flattens anIterable
ofObservableSource
s into oneObservable
, in a way that allows anObserver
to receive all successfully emitted items from each of the returnedObservableSource
s without being interrupted by an error notification from one of them, while limiting the number of concurrent subscriptions to theseObservableSource
s.final @NonNull Observable
<T> Observable.mergeWith
(@NonNull CompletableSource other) Relays the items of the currentObservable
and completes only when the otherCompletableSource
completes as well.final @NonNull Observable
<T> Observable.mergeWith
(@NonNull MaybeSource<? extends @NonNull T> other) Merges the sequence of items of the currentObservable
with the success value of the otherMaybeSource
or waits both to complete normally if theMaybeSource
is empty.final @NonNull Observable
<T> Observable.mergeWith
(@NonNull ObservableSource<? extends @NonNull T> other) Flattens the currentObservable
and anotherObservableSource
into a singleObservable
sequence, without any transformation.final @NonNull Observable
<T> Observable.mergeWith
(@NonNull SingleSource<? extends @NonNull T> other) Merges the sequence of items of the currentObservable
with the success value of the otherSingleSource
.static <@NonNull T>
@NonNull Observable<T> Observable.never()
Returns anObservable
that never sends any items or notifications to anObserver
.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.final <@NonNull U>
@NonNull Observable<U> Filters the items emitted by the currentObservable
, only emitting those of the specified type.final @NonNull Observable
<T> Observable.onErrorComplete()
Returns anObservable
instance that if the currentObservable
emits an error, it will emit anonComplete
and swallow the throwable.final @NonNull Observable
<T> Observable.onErrorComplete
(@NonNull Predicate<? super Throwable> predicate) Returns anObservable
instance that if the currentObservable
emits an error and the predicate returnstrue
, it will emit anonComplete
and swallow the throwable.final @NonNull Observable
<T> Observable.onErrorResumeNext
(@NonNull Function<? super Throwable, ? extends ObservableSource<? extends @NonNull T>> fallbackSupplier) Resumes the flow with anObservableSource
returned for the failureThrowable
of the currentObservable
by a function instead of signaling the error viaonError
.final @NonNull Observable
<T> Observable.onErrorResumeWith
(@NonNull ObservableSource<? extends @NonNull T> fallback) Resumes the flow with the givenObservableSource
when the currentObservable
fails instead of signaling the error viaonError
.final @NonNull Observable
<T> Ends the flow with a last item returned by a function for theThrowable
error signaled by the currentObservable
instead of signaling the error viaonError
.final @NonNull Observable
<T> Observable.onErrorReturnItem
(@NonNull T item) Ends the flow with the given last item when the currentObservable
fails instead of signaling the error viaonError
.final @NonNull Observable
<T> Observable.onTerminateDetach()
Nulls out references to the upstream producer and downstreamObserver
if the sequence is terminated or downstream callsdispose()
.final <@NonNull R>
@NonNull Observable<R> Observable.publish
(@NonNull Function<? super Observable<@NonNull T>, ? extends ObservableSource<@NonNull R>> selector) Returns anObservable
that emits the results of invoking a specified selector on items emitted by aConnectableObservable
that shares a single subscription to the currentObservable
sequence.static @NonNull Observable
<Integer> Observable.range
(int start, int count) Returns anObservable
that emits a sequence ofInteger
s within a specified range.static @NonNull Observable
<Long> Observable.rangeLong
(long start, long count) Returns anObservable
that emits a sequence ofLong
s within a specified range.final @NonNull Observable
<T> Observable.repeat()
Returns anObservable
that repeats the sequence of items emitted by the currentObservable
indefinitely.final @NonNull Observable
<T> Observable.repeat
(long times) Returns anObservable
that repeats the sequence of items emitted by the currentObservable
at mostcount
times.final @NonNull Observable
<T> Observable.repeatUntil
(@NonNull BooleanSupplier stop) Returns anObservable
that repeats the sequence of items emitted by the currentObservable
until the provided stop function returnstrue
.final @NonNull Observable
<T> Observable.repeatWhen
(@NonNull Function<? super Observable<Object>, ? extends ObservableSource<?>> handler) Returns anObservable
that emits the same values as the currentObservable
with the exception of anonComplete
.final <@NonNull R>
@NonNull Observable<R> Observable.replay
(@NonNull Function<? super Observable<@NonNull T>, ? extends ObservableSource<@NonNull R>> selector) Returns anObservable
that emits items that are the results of invoking a specified selector on the items emitted by aConnectableObservable
that shares a single subscription to the currentObservable
.final <@NonNull R>
@NonNull Observable<R> Observable.replay
(@NonNull Function<? super Observable<@NonNull T>, ? extends ObservableSource<@NonNull R>> selector, int bufferSize) 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
, replayingbufferSize
notifications.final <@NonNull R>
@NonNull Observable<R> Observable.replay
(@NonNull Function<? super Observable<@NonNull T>, ? extends ObservableSource<@NonNull R>> selector, int bufferSize, 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
, replayingbufferSize
notifications.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) 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) 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) 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) 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.final @NonNull Observable
<T> Observable.retry()
Returns anObservable
that mirrors the currentObservable
, resubscribing to it if it callsonError
(infinite retry count).final @NonNull Observable
<T> Observable.retry
(long times) Returns anObservable
that mirrors the currentObservable
, resubscribing to it if it callsonError
up to a specified number of retries.final @NonNull Observable
<T> Retries at most times or until the predicate returnsfalse
, whichever happens first.final @NonNull Observable
<T> Observable.retry
(@NonNull BiPredicate<? super Integer, ? super Throwable> predicate) Returns anObservable
that mirrors the currentObservable
, resubscribing to it if it callsonError
and the predicate returnstrue
for that specific exception and retry count.final @NonNull Observable
<T> Retries the currentObservable
if the predicate returnstrue
.final @NonNull Observable
<T> Observable.retryUntil
(@NonNull BooleanSupplier stop) Retries until the given stop function returnstrue
.final @NonNull Observable
<T> Observable.retryWhen
(@NonNull Function<? super Observable<Throwable>, ? extends ObservableSource<?>> handler) Returns anObservable
that emits the same values as the currentObservable
with the exception of anonError
.final @NonNull Observable
<T> Returns anObservable
that emits the most recently emitted item (if any) emitted by the currentObservable
within periodic time intervals.final @NonNull Observable
<T> Returns anObservable
that emits the most recently emitted item (if any) emitted by the currentObservable
within periodic time intervals 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
.final <@NonNull U>
@NonNull Observable<T> Observable.sample
(@NonNull ObservableSource<@NonNull U> sampler) Returns anObservable
that, when the specifiedsampler
ObservableSource
emits an item or completes, emits the most recently emitted item (if any) emitted by the currentObservable
since the previous emission from thesampler
ObservableSource
.final <@NonNull U>
@NonNull Observable<T> Observable.sample
(@NonNull ObservableSource<@NonNull U> sampler, boolean emitLast) Returns anObservable
that, when the specifiedsampler
ObservableSource
emits an item or completes, emits the most recently emitted item (if any) emitted by the currentObservable
since the previous emission from thesampler
ObservableSource
and optionally emit the very last upstream item when the upstream or otherObservableSource
complete.final @NonNull Observable
<T> Returns anObservable
that emits the first value emitted by the currentObservable
, then emits one value for each subsequent value emitted by the currentObservable
.final <@NonNull R>
@NonNull Observable<R> Observable.scan
(@NonNull R initialValue, @NonNull BiFunction<@NonNull R, ? super @NonNull T, @NonNull R> accumulator) Returns anObservable
that emits the provided initial (seed) value, then emits one value for each value emitted by the currentObservable
.final <@NonNull R>
@NonNull Observable<R> Observable.scanWith
(@NonNull Supplier<@NonNull R> seedSupplier, @NonNull BiFunction<@NonNull R, ? super @NonNull T, @NonNull R> accumulator) Returns anObservable
that emits the provided initial (seed) value, then emits one value for each value emitted by the currentObservable
.final @NonNull Observable
<T> Observable.serialize()
Forces the currentObservable
's emissions and notifications to be serialized and for it to obey theObservableSource
contract in other ways.final @NonNull Observable
<T> Observable.share()
Returns a newObservable
that multicasts (and shares a single subscription to) the currentObservable
.final @NonNull Observable
<T> Observable.skip
(long count) Returns anObservable
that skips the firstcount
items emitted by the currentObservable
and emits the remainder.final @NonNull Observable
<T> Returns anObservable
that skips values emitted by the currentObservable
before a specified time window elapses.final @NonNull Observable
<T> Returns anObservable
that skips values emitted by the currentObservable
before a specified time window on a specifiedScheduler
elapses.final @NonNull Observable
<T> Observable.skipLast
(int count) Returns anObservable
that drops a specified number of items from the end of the sequence emitted by the currentObservable
.final @NonNull Observable
<T> Returns anObservable
that drops items emitted by the currentObservable
during a specified time window before the source completes.final @NonNull Observable
<T> Returns anObservable
that drops items emitted by the currentObservable
during a specified time window 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 U>
@NonNull Observable<T> Observable.skipUntil
(@NonNull ObservableSource<@NonNull U> other) Returns anObservable
that skips items emitted by the currentObservable
until a secondObservableSource
emits an item.final @NonNull Observable
<T> Returns anObservable
that skips all items emitted by the currentObservable
as long as a specified condition holdstrue
, but emits all further source items as soon as the condition becomesfalse
.final @NonNull Observable
<T> Observable.sorted()
Returns anObservable
that emits the events emitted by the currentObservable
, in a sorted order.final @NonNull Observable
<T> Observable.sorted
(@NonNull Comparator<? super @NonNull T> comparator) Returns anObservable
that emits the events emitted by the currentObservable
, in a sorted order based on a specified comparison function.final <@NonNull T>
@NonNull Observable<T> Completable.startWith
(@NonNull ObservableSource<@NonNull T> other) Returns anObservable
which first delivers the events of the otherObservableSource
then runs the currentCompletable
.final @NonNull Observable
<T> Maybe.startWith
(@NonNull ObservableSource<@NonNull T> other) Returns anObservable
which first delivers the events of the otherObservableSource
then runs the currentMaybe
.final @NonNull Observable
<T> Observable.startWith
(@NonNull CompletableSource other) Returns anObservable
which first runs the otherCompletableSource
then the currentObservable
if the other completed normally.final @NonNull Observable
<T> Observable.startWith
(@NonNull MaybeSource<@NonNull T> other) Returns anObservable
which first runs the otherMaybeSource
then the currentObservable
if the other succeeded or completed normally.final @NonNull Observable
<T> Observable.startWith
(@NonNull ObservableSource<? extends @NonNull T> other) Returns anObservable
that emits the items in a specifiedObservableSource
before it begins to emit items emitted by the currentObservable
.final @NonNull Observable
<T> Observable.startWith
(@NonNull SingleSource<@NonNull T> other) Returns anObservable
which first runs the otherSingleSource
then the currentObservable
if the other succeeded normally.final @NonNull Observable
<T> Single.startWith
(@NonNull ObservableSource<@NonNull T> other) Returns anObservable
which first delivers the events of the otherObservableSource
then runs the currentSingle
.final @NonNull Observable
<T> Observable.startWithArray
(@NonNull T... items) Returns anObservable
that emits the specified items before it begins to emit items emitted by the currentObservable
.final @NonNull Observable
<T> Observable.startWithItem
(@NonNull T item) Returns anObservable
that emits a specified item before it begins to emit items emitted by the currentObservable
.final @NonNull Observable
<T> Observable.startWithIterable
(@NonNull Iterable<? extends @NonNull T> items) Returns anObservable
that emits the items in a specifiedIterable
before it begins to emit items emitted by the currentObservable
.final @NonNull Observable
<T> Observable.subscribeOn
(@NonNull Scheduler scheduler) final @NonNull Observable
<T> Observable.switchIfEmpty
(@NonNull ObservableSource<? extends @NonNull T> other) Returns anObservable
that emits the items emitted by the currentObservable
or the items of an alternateObservableSource
if the currentObservable
is empty.final <@NonNull R>
@NonNull Observable<R> Observable.switchMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper) Returns a newObservable
by applying a function that you supply to each item emitted by the currentObservable
that returns anObservableSource
, and then emitting the items emitted by the most recently emitted of theseObservableSource
s.final <@NonNull R>
@NonNull Observable<R> Observable.switchMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper, int bufferSize) Returns a newObservable
by applying a function that you supply to each item emitted by the currentObservable
that returns anObservableSource
, and then emitting the items emitted by the most recently emitted of theseObservableSource
s.final <@NonNull R>
@NonNull Observable<R> Observable.switchMapDelayError
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper) Returns a newObservable
by applying a function that you supply to each item emitted by the currentObservable
that returns anObservableSource
, and then emitting the items emitted by the most recently emitted of theseObservableSource
s and delays any error until allObservableSource
s terminate.final <@NonNull R>
@NonNull Observable<R> Observable.switchMapDelayError
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper, int bufferSize) Returns a newObservable
by applying a function that you supply to each item emitted by the currentObservable
that returns anObservableSource
, and then emitting the items emitted by the most recently emitted of theseObservableSource
s and delays any error until allObservableSource
s terminate.final <@NonNull R>
@NonNull Observable<R> Observable.switchMapMaybe
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Maps the items of the currentObservable
intoMaybeSource
s and switches (subscribes) to the newer ones while disposing the older ones (and ignoring their signals) and emits the latest success value of the current one if available while failing immediately if the currentObservable
or any of the active innerMaybeSource
s fail.final <@NonNull R>
@NonNull Observable<R> Observable.switchMapMaybeDelayError
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Maps the upstream items intoMaybeSource
s and switches (subscribes) to the newer ones while disposing the older ones (and ignoring their signals) and emits the latest success value of the current one if available, delaying errors from the currentObservable
or the innerMaybeSource
s until all terminate.final <@NonNull R>
@NonNull Observable<R> Observable.switchMapSingle
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper) Returns a newObservable
by applying a function that you supply to each item emitted by the currentObservable
that returns aSingleSource
, and then emitting the item emitted by the most recently emitted of theseSingleSource
s.final <@NonNull R>
@NonNull Observable<R> Observable.switchMapSingleDelayError
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper) Returns a newObservable
by applying a function that you supply to each item emitted by the currentObservable
that returns aSingleSource
, and then emitting the item emitted by the most recently emitted of theseSingleSource
s and delays any error until allSingleSource
s terminate.static <@NonNull T>
@NonNull Observable<T> Observable.switchOnNext
(@NonNull ObservableSource<? extends ObservableSource<? extends @NonNull T>> sources) Converts anObservableSource
that emitsObservableSource
s into anObservable
that emits the items emitted by the most recently emitted of thoseObservableSource
s.static <@NonNull T>
@NonNull Observable<T> Observable.switchOnNext
(@NonNull ObservableSource<? extends ObservableSource<? extends @NonNull T>> sources, int bufferSize) Converts anObservableSource
that emitsObservableSource
s into anObservable
that emits the items emitted by the most recently emitted of thoseObservableSource
s.static <@NonNull T>
@NonNull Observable<T> Observable.switchOnNextDelayError
(@NonNull ObservableSource<? extends ObservableSource<? extends @NonNull T>> sources) Converts anObservableSource
that emitsObservableSource
s into anObservable
that emits the items emitted by the most recently emitted of thoseObservableSource
s and delays any exception until allObservableSource
s terminate.static <@NonNull T>
@NonNull Observable<T> Observable.switchOnNextDelayError
(@NonNull ObservableSource<? extends ObservableSource<? extends @NonNull T>> sources, int bufferSize) Converts anObservableSource
that emitsObservableSource
s into anObservable
that emits the items emitted by the most recently emitted of thoseObservableSource
s and delays any exception until allObservableSource
s terminate.final @NonNull Observable
<T> Observable.take
(long count) Returns anObservable
that emits only the firstcount
items emitted by the currentObservable
.final @NonNull Observable
<T> Returns anObservable
that emits those items emitted by the currentObservable
before a specified time 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.final @NonNull Observable
<T> Observable.takeLast
(int count) Returns anObservable
that emits at most the lastcount
items emitted by the currentObservable
.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.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.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.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
.final <@NonNull U>
@NonNull Observable<T> Observable.takeUntil
(@NonNull ObservableSource<@NonNull U> other) Returns anObservable
that emits the items emitted by the currentObservable
until a secondObservableSource
emits an item or completes.final @NonNull Observable
<T> Returns anObservable
that emits items emitted by the currentObservable
, checks the specified predicate for each item, and then completes when the condition is satisfied.final @NonNull Observable
<T> Returns anObservable
that emits items emitted by the currentObservable
so long as each item satisfied a specified condition, and then completes as soon as this condition is not satisfied.final @NonNull Observable
<T> Observable.throttleFirst
(long windowDuration, @NonNull TimeUnit unit) Returns anObservable
that emits only the first item emitted by the currentObservable
during sequential time windows of a specified duration.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
.final @NonNull Observable
<T> Observable.throttleLast
(long intervalDuration, @NonNull TimeUnit unit) Returns anObservable
that emits only the last item emitted by the currentObservable
during sequential time windows of a specified duration.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
.final @NonNull Observable
<T> Observable.throttleLatest
(long timeout, @NonNull TimeUnit unit) 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, 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) 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.final @NonNull Observable
<T> Observable.throttleWithTimeout
(long timeout, @NonNull TimeUnit unit) 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.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
.final @NonNull Observable
<Timed<T>> Observable.timeInterval()
Returns anObservable
that emits records of the time interval between consecutive items emitted by the currentObservable
.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) Returns anObservable
that emits records of the time interval between consecutive items emitted by the currentObservable
.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
.final @NonNull Observable
<T> Returns anObservable
that mirrors the currentObservable
but applies a timeout policy for each emitted item.final @NonNull Observable
<T> Observable.timeout
(long timeout, @NonNull TimeUnit unit, @NonNull ObservableSource<? extends @NonNull T> fallback) Returns anObservable
that mirrors the currentObservable
but applies a timeout policy for each emitted item.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
.final <@NonNull U,
@NonNull V>
@NonNull Observable<T> Observable.timeout
(@NonNull ObservableSource<@NonNull U> firstTimeoutIndicator, @NonNull Function<? super @NonNull T, ? extends ObservableSource<@NonNull V>> itemTimeoutIndicator) Returns anObservable
that mirrors the currentObservable
, but notifies observers of aTimeoutException
if either the first item emitted by the currentObservable
or any subsequent item doesn't arrive within time windows defined by indicatorObservableSource
s.final <@NonNull U,
@NonNull V>
@NonNull Observable<T> Observable.timeout
(@NonNull ObservableSource<@NonNull U> firstTimeoutIndicator, @NonNull Function<? super @NonNull T, ? extends ObservableSource<@NonNull V>> itemTimeoutIndicator, @NonNull ObservableSource<? extends @NonNull T> fallback) Returns anObservable
that mirrors the currentObservable
, but switches to a fallbackObservableSource
if either the first item emitted by the currentObservable
or any subsequent item doesn't arrive within time windows defined by indicatorObservableSource
s.final <@NonNull V>
@NonNull Observable<T> Observable.timeout
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<@NonNull V>> itemTimeoutIndicator) Returns anObservable
that mirrors the currentObservable
, but notifies observers of aTimeoutException
if an item emitted by the currentObservable
doesn't arrive within a window of time after the emission of the previous item, where that period of time is measured by anObservableSource
that is a function of the previous item.final <@NonNull V>
@NonNull Observable<T> Observable.timeout
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<@NonNull V>> itemTimeoutIndicator, @NonNull ObservableSource<? extends @NonNull T> fallback) Returns anObservable
that mirrors the currentObservable
, but that switches to a fallbackObservableSource
if an item emitted by the currentObservable
doesn't arrive within a window of time after the emission of the previous item, where that period of time is measured by anObservableSource
that is a function of the previous item.private @NonNull Observable
<T> Observable.timeout0
(long timeout, @NonNull TimeUnit unit, @Nullable ObservableSource<? extends @NonNull T> fallback, @NonNull Scheduler scheduler) private <U,
V> @NonNull Observable <T> Observable.timeout0
(@NonNull ObservableSource<U> firstTimeoutIndicator, @NonNull Function<? super @NonNull T, ? extends ObservableSource<V>> itemTimeoutIndicator, @Nullable ObservableSource<? extends @NonNull T> fallback) static @NonNull Observable
<Long> Returns anObservable
that emits0L
after a specified delay, and then completes.static @NonNull Observable
<Long> Returns anObservable
that emits0L
after a specified delay, on a specifiedScheduler
, and then completes.final @NonNull Observable
<Timed<T>> Observable.timestamp()
Returns anObservable
that emits each item emitted by the currentObservable
, wrapped in aTimed
object.final @NonNull Observable
<Timed<T>> final @NonNull Observable
<Timed<T>> Returns anObservable
that emits each item emitted by the currentObservable
, wrapped in aTimed
object.final @NonNull Observable
<Timed<T>> final <@NonNull T>
@NonNull Observable<T> Completable.toObservable()
Returns anObservable
which when subscribed to subscribes to thisCompletable
and relays the terminal events to the downstreamObserver
.final @NonNull Observable
<T> Flowable.toObservable()
Converts the currentFlowable
into a non-backpressuredObservable
.final @NonNull Observable
<T> Maybe.toObservable()
Converts thisMaybe
into anObservable
instance composing disposal through.final @NonNull Observable
<T> Single.toObservable()
Converts thisSingle
into anObservable
.static <@NonNull T>
@NonNull Observable<T> Observable.unsafeCreate
(@NonNull ObservableSource<@NonNull T> onSubscribe) Create anObservable
by wrapping anObservableSource
which has to be implemented according to theObservable
specification derived from the Reactive Streams specification by handling disposal correctly; no safeguards are provided by theObservable
itself.final @NonNull Observable
<T> Observable.unsubscribeOn
(@NonNull Scheduler scheduler) static <@NonNull T,
@NonNull D>
@NonNull Observable<T> Observable.using
(@NonNull Supplier<? extends @NonNull D> resourceSupplier, @NonNull Function<? super @NonNull D, ? extends ObservableSource<? extends @NonNull T>> sourceSupplier, @NonNull Consumer<? super @NonNull D> resourceCleanup) Constructs anObservable
that creates a dependent resource object, anObservableSource
with that resource and calls the providedresourceDisposer
function if this inner source terminates or the downstream disposes the flow.static <@NonNull T,
@NonNull D>
@NonNull Observable<T> Observable.using
(@NonNull Supplier<? extends @NonNull D> resourceSupplier, @NonNull Function<? super @NonNull D, ? extends ObservableSource<? extends @NonNull T>> sourceSupplier, @NonNull Consumer<? super @NonNull D> resourceCleanup, boolean eager) Constructs anObservable
that creates a dependent resource object, anObservableSource
with that resource and calls the provideddisposer
function if this inner source terminates or the downstream disposes the flow; doing it before these end-states have been reached ifeager == true
, after otherwise.final @NonNull Observable
<Observable<T>> Observable.window
(long count) Returns anObservable
that emits windows of items it collects from the currentObservable
.final @NonNull Observable
<Observable<T>> Observable.window
(long count, long skip) Returns anObservable
that emits windows of items it collects from the currentObservable
.final @NonNull Observable
<Observable<T>> Observable.window
(long count, long skip, 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>> 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>> 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
.final <@NonNull B>
@NonNull Observable<Observable<T>> Observable.window
(@NonNull ObservableSource<@NonNull B> boundaryIndicator) Returns anObservable
that emits non-overlapping windows of items it collects from the currentObservable
where the boundary of each window is determined by the items emitted from a specified boundary-governingObservableSource
.final <@NonNull B>
@NonNull Observable<Observable<T>> Observable.window
(@NonNull ObservableSource<@NonNull B> boundaryIndicator, int bufferSize) Returns anObservable
that emits non-overlapping windows of items it collects from the currentObservable
where the boundary of each window is determined by the items emitted from a specified boundary-governingObservableSource
.final <@NonNull U,
@NonNull V>
@NonNull Observable<Observable<T>> Observable.window
(@NonNull ObservableSource<@NonNull U> openingIndicator, @NonNull Function<? super @NonNull U, ? extends ObservableSource<@NonNull V>> closingIndicator) Returns anObservable
that emits windows of items it collects from the currentObservable
.final <@NonNull U,
@NonNull V>
@NonNull Observable<Observable<T>> Observable.window
(@NonNull ObservableSource<@NonNull U> openingIndicator, @NonNull Function<? super @NonNull U, ? extends ObservableSource<@NonNull V>> closingIndicator, int bufferSize) Returns anObservable
that emits windows of items it collects from the currentObservable
.final <@NonNull R>
@NonNull Observable<R> Observable.withLatestFrom
(@NonNull ObservableSource<?>[] others, @NonNull Function<? super Object[], @NonNull R> combiner) Combines the value emission from the currentObservable
with the latest emissions from the otherObservableSource
s via a function to produce the output item.final <@NonNull U,
@NonNull R>
@NonNull Observable<R> Observable.withLatestFrom
(@NonNull ObservableSource<? extends @NonNull U> other, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> combiner) Merges the specifiedObservableSource
into the currentObservable
sequence by using theresultSelector
function only when the currentObservable
emits an item.Observable.withLatestFrom
(@NonNull ObservableSource<@NonNull T1> source1, @NonNull ObservableSource<@NonNull T2> source2, @NonNull ObservableSource<@NonNull T3> source3, @NonNull ObservableSource<@NonNull T4> source4, @NonNull Function5<? super @NonNull T, ? super @NonNull T1, ? super @NonNull T2, ? super @NonNull T3, ? super @NonNull T4, @NonNull R> combiner) Combines the value emission from the currentObservable
with the latest emissions from the otherObservableSource
s via a function to produce the output item.Observable.withLatestFrom
(@NonNull ObservableSource<@NonNull T1> source1, @NonNull ObservableSource<@NonNull T2> source2, @NonNull ObservableSource<@NonNull T3> source3, @NonNull Function4<? super @NonNull T, ? super @NonNull T1, ? super @NonNull T2, ? super @NonNull T3, @NonNull R> combiner) Combines the value emission from the currentObservable
with the latest emissions from the otherObservableSource
s via a function to produce the output item.final <@NonNull T1,
@NonNull T2, @NonNull R>
@NonNull Observable<R> Observable.withLatestFrom
(@NonNull ObservableSource<@NonNull T1> source1, @NonNull ObservableSource<@NonNull T2> source2, @NonNull Function3<? super @NonNull T, ? super @NonNull T1, ? super @NonNull T2, @NonNull R> combiner) Combines the value emission from the currentObservable
with the latest emissions from the otherObservableSource
s via a function to produce the output item.final <@NonNull R>
@NonNull Observable<R> Observable.withLatestFrom
(@NonNull Iterable<@NonNull ? extends ObservableSource<?>> others, @NonNull Function<? super Object[], @NonNull R> combiner) Combines the value emission from the currentObservable
with the latest emissions from the otherObservableSource
s via a function to produce the output item.static <@NonNull T>
@NonNull Observable<T> Observable.wrap
(@NonNull ObservableSource<@NonNull T> source) static <@NonNull T1,
@NonNull T2, @NonNull T3, @NonNull T4, @NonNull T5, @NonNull T6, @NonNull T7, @NonNull T8, @NonNull T9, @NonNull R>
@NonNull Observable<R> Observable.zip
(@NonNull ObservableSource<? extends @NonNull T1> source1, @NonNull ObservableSource<? extends @NonNull T2> source2, @NonNull ObservableSource<? extends @NonNull T3> source3, @NonNull ObservableSource<? extends @NonNull T4> source4, @NonNull ObservableSource<? extends @NonNull T5> source5, @NonNull ObservableSource<? extends @NonNull T6> source6, @NonNull ObservableSource<? extends @NonNull T7> source7, @NonNull ObservableSource<? extends @NonNull T8> source8, @NonNull ObservableSource<? extends @NonNull T9> source9, @NonNull Function9<? super @NonNull T1, ? super @NonNull T2, ? super @NonNull T3, ? super @NonNull T4, ? super @NonNull T5, ? super @NonNull T6, ? super @NonNull T7, ? super @NonNull T8, ? super @NonNull T9, ? extends @NonNull R> zipper) Returns anObservable
that emits the results of a specified combiner function applied to combinations of nine items emitted, in sequence, by nine otherObservableSource
s.static <@NonNull T1,
@NonNull T2, @NonNull T3, @NonNull T4, @NonNull T5, @NonNull T6, @NonNull T7, @NonNull T8, @NonNull R>
@NonNull Observable<R> Observable.zip
(@NonNull ObservableSource<? extends @NonNull T1> source1, @NonNull ObservableSource<? extends @NonNull T2> source2, @NonNull ObservableSource<? extends @NonNull T3> source3, @NonNull ObservableSource<? extends @NonNull T4> source4, @NonNull ObservableSource<? extends @NonNull T5> source5, @NonNull ObservableSource<? extends @NonNull T6> source6, @NonNull ObservableSource<? extends @NonNull T7> source7, @NonNull ObservableSource<? extends @NonNull T8> source8, @NonNull Function8<? super @NonNull T1, ? super @NonNull T2, ? super @NonNull T3, ? super @NonNull T4, ? super @NonNull T5, ? super @NonNull T6, ? super @NonNull T7, ? super @NonNull T8, ? extends @NonNull R> zipper) Returns anObservable
that emits the results of a specified combiner function applied to combinations of eight items emitted, in sequence, by eight otherObservableSource
s.static <@NonNull T1,
@NonNull T2, @NonNull T3, @NonNull T4, @NonNull T5, @NonNull T6, @NonNull T7, @NonNull R>
@NonNull Observable<R> Observable.zip
(@NonNull ObservableSource<? extends @NonNull T1> source1, @NonNull ObservableSource<? extends @NonNull T2> source2, @NonNull ObservableSource<? extends @NonNull T3> source3, @NonNull ObservableSource<? extends @NonNull T4> source4, @NonNull ObservableSource<? extends @NonNull T5> source5, @NonNull ObservableSource<? extends @NonNull T6> source6, @NonNull ObservableSource<? extends @NonNull T7> source7, @NonNull Function7<? super @NonNull T1, ? super @NonNull T2, ? super @NonNull T3, ? super @NonNull T4, ? super @NonNull T5, ? super @NonNull T6, ? super @NonNull T7, ? extends @NonNull R> zipper) Returns anObservable
that emits the results of a specified combiner function applied to combinations of seven items emitted, in sequence, by seven otherObservableSource
s.static <@NonNull T1,
@NonNull T2, @NonNull T3, @NonNull T4, @NonNull T5, @NonNull T6, @NonNull R>
@NonNull Observable<R> Observable.zip
(@NonNull ObservableSource<? extends @NonNull T1> source1, @NonNull ObservableSource<? extends @NonNull T2> source2, @NonNull ObservableSource<? extends @NonNull T3> source3, @NonNull ObservableSource<? extends @NonNull T4> source4, @NonNull ObservableSource<? extends @NonNull T5> source5, @NonNull ObservableSource<? extends @NonNull T6> source6, @NonNull Function6<? super @NonNull T1, ? super @NonNull T2, ? super @NonNull T3, ? super @NonNull T4, ? super @NonNull T5, ? super @NonNull T6, ? extends @NonNull R> zipper) Returns anObservable
that emits the results of a specified combiner function applied to combinations of six items emitted, in sequence, by six otherObservableSource
s.static <@NonNull T1,
@NonNull T2, @NonNull T3, @NonNull T4, @NonNull T5, @NonNull R>
@NonNull Observable<R> Observable.zip
(@NonNull ObservableSource<? extends @NonNull T1> source1, @NonNull ObservableSource<? extends @NonNull T2> source2, @NonNull ObservableSource<? extends @NonNull T3> source3, @NonNull ObservableSource<? extends @NonNull T4> source4, @NonNull ObservableSource<? extends @NonNull T5> source5, @NonNull Function5<? super @NonNull T1, ? super @NonNull T2, ? super @NonNull T3, ? super @NonNull T4, ? super @NonNull T5, ? extends @NonNull R> zipper) Returns anObservable
that emits the results of a specified combiner function applied to combinations of five items emitted, in sequence, by five otherObservableSource
s.Observable.zip
(@NonNull ObservableSource<? extends @NonNull T1> source1, @NonNull ObservableSource<? extends @NonNull T2> source2, @NonNull ObservableSource<? extends @NonNull T3> source3, @NonNull ObservableSource<? extends @NonNull T4> source4, @NonNull Function4<? super @NonNull T1, ? super @NonNull T2, ? super @NonNull T3, ? super @NonNull T4, ? extends @NonNull R> zipper) Returns anObservable
that emits the results of a specified combiner function applied to combinations of four items emitted, in sequence, by four otherObservableSource
s.Observable.zip
(@NonNull ObservableSource<? extends @NonNull T1> source1, @NonNull ObservableSource<? extends @NonNull T2> source2, @NonNull ObservableSource<? extends @NonNull T3> source3, @NonNull Function3<? super @NonNull T1, ? super @NonNull T2, ? super @NonNull T3, ? extends @NonNull R> zipper) Returns anObservable
that emits the results of a specified combiner function applied to combinations of three items emitted, in sequence, by three otherObservableSource
s.static <@NonNull T1,
@NonNull T2, @NonNull R>
@NonNull Observable<R> Observable.zip
(@NonNull ObservableSource<? extends @NonNull T1> source1, @NonNull ObservableSource<? extends @NonNull T2> source2, @NonNull BiFunction<? super @NonNull T1, ? super @NonNull T2, ? extends @NonNull R> zipper) Returns anObservable
that emits the results of a specified combiner function applied to combinations of two items emitted, in sequence, by two otherObservableSource
s.static <@NonNull T1,
@NonNull T2, @NonNull R>
@NonNull Observable<R> Observable.zip
(@NonNull ObservableSource<? extends @NonNull T1> source1, @NonNull ObservableSource<? extends @NonNull T2> source2, @NonNull BiFunction<? super @NonNull T1, ? super @NonNull T2, ? extends @NonNull R> zipper, boolean delayError) Returns anObservable
that emits the results of a specified combiner function applied to combinations of two items emitted, in sequence, by two otherObservableSource
s.static <@NonNull T1,
@NonNull T2, @NonNull R>
@NonNull Observable<R> Observable.zip
(@NonNull ObservableSource<? extends @NonNull T1> source1, @NonNull ObservableSource<? extends @NonNull T2> source2, @NonNull BiFunction<? super @NonNull T1, ? super @NonNull T2, ? extends @NonNull R> zipper, boolean delayError, int bufferSize) Returns anObservable
that emits the results of a specified combiner function applied to combinations of two items emitted, in sequence, by two otherObservableSource
s.static <@NonNull T,
@NonNull R>
@NonNull Observable<R> Observable.zip
(@NonNull Iterable<@NonNull ? extends ObservableSource<? extends @NonNull T>> sources, @NonNull Function<? super Object[], ? extends @NonNull R> zipper) Returns anObservable
that emits the results of a specified combiner function applied to combinations of items emitted, in sequence, by anIterable
of otherObservableSource
s.static <@NonNull T,
@NonNull R>
@NonNull Observable<R> Observable.zip
(@NonNull Iterable<@NonNull ? extends ObservableSource<? extends @NonNull T>> sources, @NonNull Function<? super Object[], ? extends @NonNull R> zipper, boolean delayError, int bufferSize) Returns anObservable
that emits the results of a specified combiner function applied to combinations of items emitted, in sequence, by anIterable
of otherObservableSource
s.static <@NonNull T,
@NonNull R>
@NonNull Observable<R> Observable.zipArray
(@NonNull Function<? super Object[], ? extends @NonNull R> zipper, boolean delayError, int bufferSize, @NonNull ObservableSource<? extends @NonNull T>... sources) Returns anObservable
that emits the results of a specified combiner function applied to combinations of items emitted, in sequence, by an array of otherObservableSource
s.final <@NonNull U,
@NonNull R>
@NonNull Observable<R> Observable.zipWith
(@NonNull ObservableSource<? extends @NonNull U> other, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> zipper) Returns anObservable
that emits items that are the result of applying a specified function to pairs of values, one each from the currentObservable
and another specifiedObservableSource
.final <@NonNull U,
@NonNull R>
@NonNull Observable<R> Observable.zipWith
(@NonNull ObservableSource<? extends @NonNull U> other, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> zipper, boolean delayError) Returns anObservable
that emits items that are the result of applying a specified function to pairs of values, one each from the currentObservable
and another specifiedObservableSource
.final <@NonNull U,
@NonNull R>
@NonNull Observable<R> Observable.zipWith
(@NonNull ObservableSource<? extends @NonNull U> other, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> zipper, boolean delayError, int bufferSize) Returns anObservable
that emits items that are the result of applying a specified function to pairs of values, one each from the currentObservable
and another specifiedObservableSource
.final <@NonNull U,
@NonNull R>
@NonNull Observable<R> Observable.zipWith
(@NonNull Iterable<@NonNull U> other, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> zipper) Returns anObservable
that emits items that are the result of applying a specified function to pairs of values, one each from the currentObservable
and a specifiedIterable
sequence.Methods in io.reactivex.rxjava3.core that return types with arguments of type ObservableModifier and TypeMethodDescriptionfinal @NonNull Observable
<Observable<T>> Observable.window
(long count) Returns anObservable
that emits windows of items it collects from the currentObservable
.final @NonNull Observable
<Observable<T>> Observable.window
(long count, long skip) Returns anObservable
that emits windows of items it collects from the currentObservable
.final @NonNull Observable
<Observable<T>> Observable.window
(long count, long skip, 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>> 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>> 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
.final <@NonNull B>
@NonNull Observable<Observable<T>> Observable.window
(@NonNull ObservableSource<@NonNull B> boundaryIndicator) Returns anObservable
that emits non-overlapping windows of items it collects from the currentObservable
where the boundary of each window is determined by the items emitted from a specified boundary-governingObservableSource
.final <@NonNull B>
@NonNull Observable<Observable<T>> Observable.window
(@NonNull ObservableSource<@NonNull B> boundaryIndicator, int bufferSize) Returns anObservable
that emits non-overlapping windows of items it collects from the currentObservable
where the boundary of each window is determined by the items emitted from a specified boundary-governingObservableSource
.final <@NonNull U,
@NonNull V>
@NonNull Observable<Observable<T>> Observable.window
(@NonNull ObservableSource<@NonNull U> openingIndicator, @NonNull Function<? super @NonNull U, ? extends ObservableSource<@NonNull V>> closingIndicator) Returns anObservable
that emits windows of items it collects from the currentObservable
.final <@NonNull U,
@NonNull V>
@NonNull Observable<Observable<T>> Observable.window
(@NonNull ObservableSource<@NonNull U> openingIndicator, @NonNull Function<? super @NonNull U, ? extends ObservableSource<@NonNull V>> closingIndicator, int bufferSize) Returns anObservable
that emits windows of items it collects from the currentObservable
.Methods in io.reactivex.rxjava3.core with parameters of type ObservableModifier and TypeMethodDescriptionObservableConverter.apply
(@NonNull Observable<@NonNull T> upstream) Applies a function to the upstreamObservable
and returns a converted value of typeR
.ObservableTransformer.apply
(@NonNull Observable<@NonNull Upstream> upstream) Applies a function to the upstreamObservable
and returns anObservableSource
with optionally different element type.Method parameters in io.reactivex.rxjava3.core with type arguments of type ObservableModifier and TypeMethodDescriptionObservable.groupJoin
(@NonNull ObservableSource<? extends @NonNull TRight> other, @NonNull Function<? super @NonNull T, ? extends ObservableSource<@NonNull TLeftEnd>> leftEnd, @NonNull Function<? super @NonNull TRight, ? extends ObservableSource<@NonNull TRightEnd>> rightEnd, @NonNull BiFunction<? super @NonNull T, ? super Observable<@NonNull TRight>, ? extends @NonNull R> resultSelector) Returns anObservable
that correlates twoObservableSource
s when they overlap in time and groups the results.final <@NonNull R>
@NonNull Observable<R> Observable.publish
(@NonNull Function<? super Observable<@NonNull T>, ? extends ObservableSource<@NonNull R>> selector) Returns anObservable
that emits the results of invoking a specified selector on items emitted by aConnectableObservable
that shares a single subscription to the currentObservable
sequence.final @NonNull Observable
<T> Observable.repeatWhen
(@NonNull Function<? super Observable<Object>, ? extends ObservableSource<?>> handler) Returns anObservable
that emits the same values as the currentObservable
with the exception of anonComplete
.final <@NonNull R>
@NonNull Observable<R> Observable.replay
(@NonNull Function<? super Observable<@NonNull T>, ? extends ObservableSource<@NonNull R>> selector) Returns anObservable
that emits items that are the results of invoking a specified selector on the items emitted by aConnectableObservable
that shares a single subscription to the currentObservable
.final <@NonNull R>
@NonNull Observable<R> Observable.replay
(@NonNull Function<? super Observable<@NonNull T>, ? extends ObservableSource<@NonNull R>> selector, int bufferSize) 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
, replayingbufferSize
notifications.final <@NonNull R>
@NonNull Observable<R> Observable.replay
(@NonNull Function<? super Observable<@NonNull T>, ? extends ObservableSource<@NonNull R>> selector, int bufferSize, 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
, replayingbufferSize
notifications.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) 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) 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) 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) 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.final @NonNull Observable
<T> Observable.retryWhen
(@NonNull Function<? super Observable<Throwable>, ? extends ObservableSource<?>> handler) Returns anObservable
that emits the same values as the currentObservable
with the exception of anonError
. -
Uses of Observable in io.reactivex.rxjava3.internal.fuseable
Methods in io.reactivex.rxjava3.internal.fuseable that return ObservableModifier and TypeMethodDescriptionFuseToObservable.fuseToObservable()
Returns a (direct) Observable for the operator. -
Uses of Observable in io.reactivex.rxjava3.internal.jdk8
Subclasses of Observable in io.reactivex.rxjava3.internal.jdk8Modifier and TypeClassDescriptionfinal class
Map the success value into a JavaStream
and emits its values.final class
Collect items into a container defined by a StreamCollector
callback set.final class
Maps the upstream values ontoStream
s and emits their items in order to the downstream.final class
Wrap a CompletionStage and signal its outcome.final class
Wraps aStream
and emits its values as anObservable
sequence.final class
Map the upstream values into an Optional and emit its value if any.final class
Map the success value into a JavaStream
and emits its values.Fields in io.reactivex.rxjava3.internal.jdk8 declared as ObservableModifier and TypeFieldDescription(package private) final Observable
<T> ObservableCollectWithCollector.source
(package private) final Observable
<T> ObservableCollectWithCollectorSingle.source
(package private) final Observable
<T> ObservableFlatMapStream.source
(package private) final Observable
<T> ObservableMapOptional.source
Methods in io.reactivex.rxjava3.internal.jdk8 that return ObservableConstructors in io.reactivex.rxjava3.internal.jdk8 with parameters of type ObservableModifierConstructorDescriptionObservableCollectWithCollector
(Observable<T> source, Collector<? super T, A, R> collector) ObservableCollectWithCollectorSingle
(Observable<T> source, Collector<? super T, A, R> collector) ObservableFlatMapStream
(Observable<T> source, Function<? super T, ? extends Stream<? extends R>> mapper) ObservableMapOptional
(Observable<T> source, Function<? super T, Optional<? extends R>> mapper) -
Uses of Observable in io.reactivex.rxjava3.internal.operators.completable
Subclasses of Observable in io.reactivex.rxjava3.internal.operators.completableModifier and TypeClassDescriptionfinal class
Wraps a Completable and exposes it as an Observable. -
Uses of Observable in io.reactivex.rxjava3.internal.operators.maybe
Subclasses of Observable in io.reactivex.rxjava3.internal.operators.maybeModifier and TypeClassDescriptionfinal class
Maps a success value into an Iterable and streams it back as a Flowable.final class
Wraps a MaybeSource and exposes it as an Observable, relaying signals in a backpressure-aware manner and composes cancellation through. -
Uses of Observable in io.reactivex.rxjava3.internal.operators.mixed
Subclasses of Observable in io.reactivex.rxjava3.internal.operators.mixedModifier and TypeClassDescriptionfinal class
After Completable completes, it relays the signals of the ObservableSource to the downstream observer.final class
Maps the success value of a Maybe onto an ObservableSource and relays its signals to the downstream observer.final class
Maps each upstream item into aMaybeSource
, subscribes to them one after the other terminates and relays their success values, optionally delaying any errors till the main and inner sources terminate.final class
Maps each upstream item into aSingleSource
, subscribes to them one after the other terminates and relays their success values, optionally delaying any errors till the main and inner sources terminate.final class
Maps the upstream items intoMaybeSource
s and switches (subscribes) to the newer ones while disposing the older ones and emits the latest success value if available, optionally delaying errors from the main source or the inner sources.final class
Maps the upstream items intoSingleSource
s and switches (subscribes) to the newer ones while disposing the older ones and emits the latest success value if available, optionally delaying errors from the main source or the inner sources.final class
Maps the success value of a Single onto an ObservableSource and relays its signals to the downstream observer.Fields in io.reactivex.rxjava3.internal.operators.mixed declared as ObservableModifier and TypeFieldDescription(package private) final Observable
<T> ObservableConcatMapCompletable.source
(package private) final Observable
<T> ObservableConcatMapMaybe.source
(package private) final Observable
<T> ObservableSwitchMapCompletable.source
(package private) final Observable
<T> ObservableSwitchMapMaybe.source
(package private) final Observable
<T> ObservableSwitchMapSingle.source
Constructors in io.reactivex.rxjava3.internal.operators.mixed with parameters of type ObservableModifierConstructorDescriptionObservableConcatMapCompletable
(Observable<T> source, Function<? super T, ? extends CompletableSource> mapper, ErrorMode errorMode, int prefetch) ObservableConcatMapMaybe
(Observable<T> source, Function<? super T, ? extends MaybeSource<? extends R>> mapper, ErrorMode errorMode, int prefetch) ObservableSwitchMapCompletable
(Observable<T> source, Function<? super T, ? extends CompletableSource> mapper, boolean delayErrors) ObservableSwitchMapMaybe
(Observable<T> source, Function<? super T, ? extends MaybeSource<? extends R>> mapper, boolean delayErrors) ObservableSwitchMapSingle
(Observable<T> source, Function<? super T, ? extends SingleSource<? extends R>> mapper, boolean delayErrors) -
Uses of Observable in io.reactivex.rxjava3.internal.operators.observable
Subclasses of Observable in io.reactivex.rxjava3.internal.operators.observableModifier and TypeClassDescription(package private) class
Base class for operators with a source consumable.final class
final class
final class
final class
Wraps a ConnectableObservable and calls its connect() method once the specified number of Observers have subscribed.final class
ObservableBuffer<T,
U extends Collection<? super T>> final class
ObservableBufferBoundary<T,
U extends Collection<? super T>, Open, Close> final class
ObservableBufferExactBoundary<T,
U extends Collection<? super T>, B> final class
ObservableBufferTimed<T,
U extends Collection<? super T>> final class
An observable which auto-connects to another observable, caches the elements from that observable but allows terminating the connection and completing the cache.final class
ObservableCollect<T,
U> final class
final class
ObservableConcatMap<T,
U> final class
final class
final class
Subscribe to a main Observable first, then when it completes normally, subscribe to a Single, signal its success value followed by a completion or signal its error as is.final class
Subscribe to a main Observable first, then when it completes normally, subscribe to a Maybe, signal its success value followed by a completion or signal its error or completion signal as is.final class
Subscribe to a main Observable first, then when it completes normally, subscribe to a Single, signal its success value followed by a completion or signal its error as is.final class
final class
final class
ObservableDebounce<T,
U> final class
final class
final class
final class
Delays the subscription to the main source until the other observable fires an event or completes.final class
final class
Breaks the links between the upstream and the downstream (the Disposable and the Observer references) when the sequence terminates or gets disposed.final class
ObservableDistinct<T,
K> final class
final class
Calls a consumer after pushing the current item to the downstream.final class
Execute an action after an onError, onComplete or a dispose event.final class
final class
final class
final class
final class
final class
final class
ObservableFlatMap<T,
U> final class
Maps a sequence of values into CompletableSources and awaits their termination.final class
Maps upstream values into MaybeSources and merges their signals into one sequence.final class
Maps upstream values into SingleSources and merges their signals into one sequence.final class
Maps a sequence into an Iterable and emits its values.final class
Executes anAction
and signals its exception or completes normally.final class
final class
Calls a Callable and emits its resulting single value or signals its exception.final class
Wrap a Completable into an Observable.final class
final class
final class
final class
Executes anRunnable
and signals its exception or completes normally.final class
Calls a Supplier and emits its resulting single value or signals its exception.final class
final class
ObservableGenerate<T,
S> final class
ObservableGroupBy<T,
K, V> (package private) static final class
final class
ObservableGroupJoin<TLeft,
TRight, TLeftEnd, TRightEnd, R> final class
Hides the identity of the wrapped ObservableSource and its Disposable.final class
final class
final class
final class
ObservableJoin<TLeft,
TRight, TLeftEnd, TRightEnd, R> final class
Represents a constant scalar value.final class
ObservableLift<R,
T> Allows lifting operators into a chain of Observables.final class
ObservableMap<T,
U> final class
final class
final class
Merges an Observable and a Completable by emitting the items of the Observable and waiting until both the Observable and Completable complete normally.final class
Merges an Observable and a Maybe by emitting the items of the Observable and the success value of the Maybe and waiting until both the Observable and Maybe terminate normally.final class
Merges an Observable and a Single by emitting the items of the Observable and the success value of the Single and waiting until both the Observable and Single terminate normally.final class
final class
final class
Emits an onComplete if the source emits an onError and the predicate returns true for that Throwable.final class
final class
final class
Shares a single underlying connection to the upstream ObservableSource and multicasts events to all subscribed observers until the upstream completes or the connection is disposed.final class
Shares a source Observable for the duration of a selector function.final class
Emits a range of integer values from start to end.final class
final class
Returns an observable sequence that stays connected to the source as long as there is at least one subscription to the observable sequence.final class
final class
final class
Repeatedly subscribe to a source if a handler ObservableSource signals an item.final class
(package private) static final class
final class
final class
final class
Repeatedly subscribe to a source if a handler ObservableSource signals an item.final class
final class
(package private) static final class
Maps a scalar value to an ObservableSource and subscribes to it.final class
final class
ObservableScanSeed<T,
R> final class
final class
final class
final class
final class
final class
ObservableSkipUntil<T,
U> final class
final class
final class
final class
ObservableSwitchMap<T,
R> final class
final class
final class
final class
final class
ObservableTakeUntil<T,
U> final class
final class
final class
final class
Emits the next or latest item when the given time elapses.final class
final class
ObservableTimeout<T,
U, V> final class
final class
final class
ObservableToList<T,
U extends Collection<? super T>> final class
final class
ObservableUsing<T,
D> final class
final class
final class
(package private) static final class
(package private) final class
Wrapper for a Subject that detects an incoming subscriber.final class
final class
ObservableWithLatestFrom<T,
U, R> final class
Combines a main sequence of values with the latest from multiple other sequences via a selector function.final class
ObservableZip<T,
R> final class
ObservableZipIterable<T,
U, V> Fields in io.reactivex.rxjava3.internal.operators.observable declared as ObservableModifier and TypeFieldDescriptionstatic final Observable
<Object> ObservableEmpty.INSTANCE
static final Observable
<Object> ObservableNever.INSTANCE
(package private) final Observable
<T> ObservableInternalHelper.BufferedReplaySupplier.parent
(package private) final Observable
<T> ObservableInternalHelper.BufferedTimedReplaySupplier.parent
private final Observable
<T> ObservableInternalHelper.ReplaySupplier.parent
(package private) final Observable
<T> ObservableInternalHelper.TimedReplayCallable.parent
(package private) final Observable
<? extends T> ObservableZipIterable.source
Fields in io.reactivex.rxjava3.internal.operators.observable with type parameters of type ObservableModifier and TypeFieldDescription(package private) final Observer
<? super Observable<T>> ObservableWindow.WindowExactObserver.downstream
(package private) final Observer
<? super Observable<T>> ObservableWindow.WindowSkipObserver.downstream
(package private) final Observer
<? super Observable<T>> ObservableWindowBoundary.WindowBoundaryMainObserver.downstream
(package private) final Observer
<? super Observable<T>> ObservableWindowBoundarySelector.WindowBoundaryMainObserver.downstream
(package private) final Observer
<? super Observable<T>> ObservableWindowTimed.AbstractWindowObserver.downstream
(package private) final Function
<? super Observable<Object>, ? extends ObservableSource<?>> ObservableRepeatWhen.handler
(package private) final Function
<? super Observable<Throwable>, ? extends ObservableSource<?>> ObservableRetryWhen.handler
(package private) final BiFunction
<? super TLeft, ? super Observable<TRight>, ? extends R> ObservableGroupJoin.GroupJoinDisposable.resultSelector
(package private) final BiFunction
<? super TLeft, ? super Observable<TRight>, ? extends R> ObservableGroupJoin.resultSelector
(package private) final Function
<? super Observable<T>, ? extends ObservableSource<R>> ObservablePublishSelector.selector
private final Function
<? super Observable<U>, ? extends ObservableSource<R>> ObservableReplay.MulticastReplay.selector
Methods in io.reactivex.rxjava3.internal.operators.observable that return ObservableModifier and TypeMethodDescriptionObservableAllSingle.fuseToObservable()
ObservableAnySingle.fuseToObservable()
ObservableCollectSingle.fuseToObservable()
ObservableCountSingle.fuseToObservable()
ObservableElementAtMaybe.fuseToObservable()
ObservableElementAtSingle.fuseToObservable()
ObservableFlatMapCompletableCompletable.fuseToObservable()
ObservableIgnoreElementsCompletable.fuseToObservable()
ObservableSequenceEqualSingle.fuseToObservable()
ObservableToListSingle.fuseToObservable()
static <U,
R> Observable <R> ObservableReplay.multicastSelector
(Supplier<? extends ConnectableObservable<U>> connectableFactory, Function<? super Observable<U>, ? extends ObservableSource<R>> selector) Given a connectable observable factory, it multicasts over the generated ConnectableObservable via a selector function.static <T,
U> Observable <U> ObservableScalarXMap.scalarXMap
(T value, Function<? super T, ? extends ObservableSource<? extends U>> mapper) Maps a scalar value into an Observable and emits its values.Methods in io.reactivex.rxjava3.internal.operators.observable with parameters of type ObservableModifier and TypeMethodDescriptionstatic <T> Supplier
<ConnectableObservable<T>> ObservableInternalHelper.replaySupplier
(Observable<T> parent) static <T> Supplier
<ConnectableObservable<T>> ObservableInternalHelper.replaySupplier
(Observable<T> parent, int bufferSize, boolean eagerTruncate) 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) Method parameters in io.reactivex.rxjava3.internal.operators.observable with type arguments of type ObservableModifier and TypeMethodDescriptionstatic <U,
R> Observable <R> ObservableReplay.multicastSelector
(Supplier<? extends ConnectableObservable<U>> connectableFactory, Function<? super Observable<U>, ? extends ObservableSource<R>> selector) Given a connectable observable factory, it multicasts over the generated ConnectableObservable via a selector function.void
ObservableWindow.subscribeActual
(Observer<? super Observable<T>> t) void
ObservableWindowBoundary.subscribeActual
(Observer<? super Observable<T>> observer) void
ObservableWindowBoundarySelector.subscribeActual
(Observer<? super Observable<T>> t) protected void
ObservableWindowTimed.subscribeActual
(Observer<? super Observable<T>> downstream) Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type ObservableModifierConstructorDescription(package private)
BufferedReplaySupplier
(Observable<T> parent, int bufferSize, boolean eagerTruncate) (package private)
BufferedTimedReplaySupplier
(Observable<T> parent, int bufferSize, long time, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate) ObservableCache
(Observable<T> source, int capacityHint) Constructs an empty, non-connected cache.ObservableConcatWithCompletable
(Observable<T> source, CompletableSource other) ObservableConcatWithMaybe
(Observable<T> source, MaybeSource<? extends T> other) ObservableConcatWithSingle
(Observable<T> source, SingleSource<? extends T> other) ObservableDoOnLifecycle
(Observable<T> upstream, Consumer<? super Disposable> onSubscribe, Action onDispose) ObservableMergeWithCompletable
(Observable<T> source, CompletableSource other) ObservableMergeWithMaybe
(Observable<T> source, MaybeSource<? extends T> other) ObservableMergeWithSingle
(Observable<T> source, SingleSource<? extends T> other) ObservableRepeat
(Observable<T> source, long count) ObservableRepeatUntil
(Observable<T> source, BooleanSupplier until) ObservableRetryBiPredicate
(Observable<T> source, BiPredicate<? super Integer, ? super Throwable> predicate) ObservableRetryPredicate
(Observable<T> source, long count, Predicate<? super Throwable> predicate) ObservableSerialized
(Observable<T> upstream) ObservableThrottleLatest
(Observable<T> source, long timeout, TimeUnit unit, Scheduler scheduler, boolean emitLast, Consumer<? super T> onDropped) ObservableTimeout
(Observable<T> source, ObservableSource<U> firstTimeoutIndicator, Function<? super T, ? extends ObservableSource<V>> itemTimeoutIndicator, ObservableSource<? extends T> other) ObservableTimeoutTimed
(Observable<T> source, long timeout, TimeUnit unit, Scheduler scheduler, ObservableSource<? extends T> other) ObservableWindowTimed
(Observable<T> source, long timespan, long timeskip, TimeUnit unit, Scheduler scheduler, long maxSize, int bufferSize, boolean restartTimerOnMaxSize) ObservableZipIterable
(Observable<? extends T> source, Iterable<U> other, BiFunction<? super T, ? super U, ? extends V> zipper) (package private)
ReplaySupplier
(Observable<T> parent) (package private)
TimedReplayCallable
(Observable<T> parent, long time, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate) Constructor parameters in io.reactivex.rxjava3.internal.operators.observable with type arguments of type ObservableModifierConstructorDescription(package private)
AbstractWindowObserver
(Observer<? super Observable<T>> downstream, long timespan, TimeUnit unit, int bufferSize) (package private)
GroupJoinDisposable
(Observer<? super R> actual, Function<? super TLeft, ? extends ObservableSource<TLeftEnd>> leftEnd, Function<? super TRight, ? extends ObservableSource<TRightEnd>> rightEnd, BiFunction<? super TLeft, ? super Observable<TRight>, ? extends R> resultSelector) (package private)
MulticastReplay
(Supplier<? extends ConnectableObservable<U>> connectableFactory, Function<? super Observable<U>, ? extends ObservableSource<R>> selector) ObservableGroupJoin
(ObservableSource<TLeft> source, ObservableSource<? extends TRight> other, Function<? super TLeft, ? extends ObservableSource<TLeftEnd>> leftEnd, Function<? super TRight, ? extends ObservableSource<TRightEnd>> rightEnd, BiFunction<? super TLeft, ? super Observable<TRight>, ? extends R> resultSelector) ObservablePublishSelector
(ObservableSource<T> source, Function<? super Observable<T>, ? extends ObservableSource<R>> selector) ObservableRepeatWhen
(ObservableSource<T> source, Function<? super Observable<Object>, ? extends ObservableSource<?>> handler) ObservableRetryWhen
(ObservableSource<T> source, Function<? super Observable<Throwable>, ? extends ObservableSource<?>> handler) (package private)
WindowBoundaryMainObserver
(Observer<? super Observable<T>> downstream, int capacityHint) (package private)
WindowBoundaryMainObserver
(Observer<? super Observable<T>> downstream, ObservableSource<B> open, Function<? super B, ? extends ObservableSource<V>> closingIndicator, int bufferSize) (package private)
WindowExactBoundedObserver
(Observer<? super Observable<T>> actual, long timespan, TimeUnit unit, Scheduler scheduler, int bufferSize, long maxSize, boolean restartTimerOnMaxSize) (package private)
WindowExactObserver
(Observer<? super Observable<T>> actual, long count, int capacityHint) (package private)
WindowExactUnboundedObserver
(Observer<? super Observable<T>> actual, long timespan, TimeUnit unit, Scheduler scheduler, int bufferSize) (package private)
WindowSkipObserver
(Observer<? super Observable<T>> actual, long count, long skip, int capacityHint) (package private)
WindowSkipObserver
(Observer<? super Observable<T>> actual, long timespan, long timeskip, TimeUnit unit, Scheduler.Worker worker, int bufferSize) -
Uses of Observable in io.reactivex.rxjava3.internal.operators.single
Subclasses of Observable in io.reactivex.rxjava3.internal.operators.singleModifier and TypeClassDescriptionfinal class
Maps a success value into an Iterable and streams it back as an Observable.final class
Wraps a Single and exposes it as an Observable. -
Uses of Observable in io.reactivex.rxjava3.observables
Subclasses of Observable in io.reactivex.rxjava3.observablesModifier and TypeClassDescriptionclass
AConnectableObservable
resembles an ordinaryObservable
, except that it does not begin emitting items when it is subscribed to, but only when itsConnectableObservable.connect(io.reactivex.rxjava3.functions.Consumer<? super io.reactivex.rxjava3.disposables.Disposable>)
method is called.class
GroupedObservable<K,
T> AnObservable
that has been grouped by key, the value of which can be obtained withGroupedObservable.getKey()
.Methods in io.reactivex.rxjava3.observables that return ObservableModifier and TypeMethodDescriptionConnectableObservable.autoConnect()
Returns anObservable
that automatically connects (at most once) to thisConnectableObservable
when the firstObserver
subscribes.ConnectableObservable.autoConnect
(int numberOfObservers) Returns anObservable
that automatically connects (at most once) to thisConnectableObservable
when the specified number ofObserver
s subscribe to it.ConnectableObservable.autoConnect
(int numberOfObservers, @NonNull Consumer<? super Disposable> connection) Returns anObservable
that automatically connects (at most once) to thisConnectableObservable
when the specified number ofObserver
s subscribe to it and calls the specified callback with theDisposable
associated with the established connection.ConnectableObservable.refCount()
Returns anObservable
that stays connected to thisConnectableObservable
as long as there is at least one subscription to thisConnectableObservable
.final @NonNull Observable
<T> ConnectableObservable.refCount
(int observerCount) Connects to the upstreamConnectableObservable
if the number of subscribed observers reaches the specified count and disconnect if allObserver
s have unsubscribed.final @NonNull Observable
<T> 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> 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.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 Observable in io.reactivex.rxjava3.plugins
Fields in io.reactivex.rxjava3.plugins with type parameters of type ObservableModifier and TypeFieldDescription(package private) static @Nullable Function
<? super Observable, ? extends Observable> RxJavaPlugins.onObservableAssembly
(package private) static @Nullable Function
<? super Observable, ? extends Observable> RxJavaPlugins.onObservableAssembly
(package private) static @Nullable BiFunction
<? super Observable, @NonNull ? super Observer, @NonNull ? extends Observer> RxJavaPlugins.onObservableSubscribe
Methods in io.reactivex.rxjava3.plugins that return ObservableModifier and TypeMethodDescriptionstatic <@NonNull T>
@NonNull Observable<T> RxJavaPlugins.onAssembly
(@NonNull Observable<@NonNull T> source) Calls the associated hook function.Methods in io.reactivex.rxjava3.plugins that return types with arguments of type ObservableModifier and TypeMethodDescriptionstatic @Nullable Function
<? super Observable, ? extends Observable> RxJavaPlugins.getOnObservableAssembly()
Returns the current hook function.static @Nullable Function
<? super Observable, ? extends Observable> RxJavaPlugins.getOnObservableAssembly()
Returns the current hook function.static @Nullable BiFunction
<? super Observable, @NonNull ? super Observer, @NonNull ? extends Observer> RxJavaPlugins.getOnObservableSubscribe()
Returns the current hook function.Methods in io.reactivex.rxjava3.plugins with parameters of type ObservableModifier and TypeMethodDescriptionstatic <@NonNull T>
@NonNull Observable<T> RxJavaPlugins.onAssembly
(@NonNull Observable<@NonNull T> source) Calls the associated hook function.RxJavaPlugins.onSubscribe
(@NonNull Observable<@NonNull T> source, @NonNull Observer<? super @NonNull T> observer) Calls the associated hook function.Method parameters in io.reactivex.rxjava3.plugins with type arguments of type ObservableModifier and TypeMethodDescriptionstatic void
RxJavaPlugins.setOnObservableAssembly
(@Nullable Function<? super Observable, ? extends Observable> onObservableAssembly) Sets the specific hook function.static void
RxJavaPlugins.setOnObservableAssembly
(@Nullable Function<? super Observable, ? extends Observable> onObservableAssembly) Sets the specific hook function.static void
RxJavaPlugins.setOnObservableSubscribe
(@Nullable BiFunction<? super Observable, @NonNull ? super Observer, @NonNull ? extends Observer> onObservableSubscribe) Sets the specific hook function. -
Uses of Observable in io.reactivex.rxjava3.subjects
Subclasses of Observable in io.reactivex.rxjava3.subjectsModifier and TypeClassDescriptionfinal class
AsyncSubject<T>
A Subject that emits the very last value followed by a completion event or the received error to Observers.final class
Subject that emits the most recent item it has observed and all subsequent observed items to each subscribedObserver
.final class
A Subject that emits (multicasts) items to currently subscribedObserver
s and terminal events to current or lateObserver
s.final class
Replays events (in a configurable bounded or unbounded manner) to current and lateObserver
s.(package private) final class
Serializes calls to the Observer methods.class
Subject<T>
Represents anObserver
and anObservable
at the same time, allowing multicasting events from a single source to multiple childObserver
s.final class
A Subject that queues up events until a singleObserver
subscribes to it, replays those events to it until theObserver
catches up and then switches to relaying events live to this singleObserver
until thisUnicastSubject
terminates or theObserver
disposes.