Package | Description |
---|---|
io.reactivex |
Base reactive classes:
Flowable , Observable ,
Single , Maybe and
Completable ; base reactive consumers;
other common base interfaces. |
io.reactivex.internal.fuseable |
Base interfaces and types for supporting operator-fusion.
|
io.reactivex.internal.operators.completable | |
io.reactivex.internal.operators.maybe | |
io.reactivex.internal.operators.mixed | |
io.reactivex.internal.operators.observable | |
io.reactivex.internal.operators.single | |
io.reactivex.observables |
Classes supporting the Observable base reactive class:
ConnectableObservable and
GroupedObservable . |
io.reactivex.subjects |
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.
|
Modifier and Type | Class and Description |
---|---|
class |
Observable<T>
The Observable class is the non-backpressured, optionally multi-valued base reactive class that
offers factory methods, intermediate operators and the ability to consume synchronous
and/or asynchronous reactive dataflows.
|
Modifier and Type | Method and Description |
---|---|
ObservableSource<Downstream> |
ObservableTransformer.apply(Observable<Upstream> upstream)
Applies a function to the upstream Observable and returns an ObservableSource with
optionally different element type.
|
Modifier and Type | Method and Description |
---|---|
static <T> Observable<T> |
Observable.ambArray(ObservableSource<? extends T>... sources)
Mirrors the one ObservableSource in an array of several ObservableSources that first either emits an item or sends
a termination notification.
|
Observable<T> |
Observable.ambWith(ObservableSource<? extends T> other)
Mirrors the ObservableSource (current or provided) that first either emits an item or sends a termination
notification.
|
<T> Observable<T> |
Completable.andThen(ObservableSource<T> next)
Returns an Observable which will subscribe to this Completable and once that is completed then
will subscribe to the
next ObservableSource. |
<TOpening,TClosing> |
Observable.buffer(ObservableSource<? extends TOpening> openingIndicator,
Function<? super TOpening,? extends ObservableSource<? extends TClosing>> closingIndicator)
Returns an Observable that emits buffers of items it collects from the source ObservableSource.
|
<TOpening,TClosing,U extends Collection<? super T>> |
Observable.buffer(ObservableSource<? extends TOpening> openingIndicator,
Function<? super TOpening,? extends ObservableSource<? extends TClosing>> closingIndicator,
Callable<U> bufferSupplier)
Returns an Observable that emits buffers of items it collects from the source ObservableSource.
|
<B> Observable<List<T>> |
Observable.buffer(ObservableSource<B> boundary)
Returns an Observable that emits non-overlapping buffered items from the source ObservableSource each time the
specified boundary ObservableSource emits an item.
|
<B,U extends Collection<? super T>> |
Observable.buffer(ObservableSource<B> boundary,
Callable<U> bufferSupplier)
Returns an Observable that emits non-overlapping buffered items from the source ObservableSource each time the
specified boundary ObservableSource emits an item.
|
<B> Observable<List<T>> |
Observable.buffer(ObservableSource<B> boundary,
int initialCapacity)
Returns an Observable that emits non-overlapping buffered items from the source ObservableSource each time the
specified boundary ObservableSource emits an item.
|
static <T,R> Observable<R> |
Observable.combineLatest(Function<? super Object[],? extends R> combiner,
int bufferSize,
ObservableSource<? extends T>... sources)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T,R> Observable<R> |
Observable.combineLatest(ObservableSource<? extends T>[] sources,
Function<? super Object[],? extends R> combiner)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T,R> Observable<R> |
Observable.combineLatest(ObservableSource<? extends T>[] sources,
Function<? super Object[],? extends R> combiner,
int bufferSize)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,R> Observable<R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
BiFunction<? super T1,? super T2,? extends R> combiner)
Combines two source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from either of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,R> Observable<R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
BiFunction<? super T1,? super T2,? extends R> combiner)
Combines two source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from either of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
Function3<? super T1,? super T2,? super T3,? extends R> combiner)
Combines three source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
Function3<? super T1,? super T2,? super T3,? extends R> combiner)
Combines three source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
Function3<? super T1,? super T2,? super T3,? extends R> combiner)
Combines three source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
Function4<? super T1,? super T2,? super T3,? super T4,? extends R> combiner)
Combines four source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
Function4<? super T1,? super T2,? super T3,? super T4,? extends R> combiner)
Combines four source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
Function4<? super T1,? super T2,? super T3,? super T4,? extends R> combiner)
Combines four source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
Function4<? super T1,? super T2,? super T3,? super T4,? extends R> combiner)
Combines four source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
Function5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> combiner)
Combines five source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
Function5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> combiner)
Combines five source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
Function5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> combiner)
Combines five source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
Function5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> combiner)
Combines five source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
Function5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> combiner)
Combines five source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
Function6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> combiner)
Combines six source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
Function6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> combiner)
Combines six source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
Function6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> combiner)
Combines six source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
Function6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> combiner)
Combines six source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
Function6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> combiner)
Combines six source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
Function6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> combiner)
Combines six source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
Function7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> combiner)
Combines seven source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
Function7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> combiner)
Combines seven source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
Function7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> combiner)
Combines seven source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
Function7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> combiner)
Combines seven source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
Function7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> combiner)
Combines seven source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
Function7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> combiner)
Combines seven source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
Function7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> combiner)
Combines seven source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
Function8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> combiner)
Combines eight source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
Function8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> combiner)
Combines eight source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
Function8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> combiner)
Combines eight source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
Function8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> combiner)
Combines eight source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
Function8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> combiner)
Combines eight source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
Function8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> combiner)
Combines eight source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
Function8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> combiner)
Combines eight source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
Function8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> combiner)
Combines eight source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
ObservableSource<? extends T9> source9,
Function9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> combiner)
Combines nine source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
ObservableSource<? extends T9> source9,
Function9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> combiner)
Combines nine source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
ObservableSource<? extends T9> source9,
Function9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> combiner)
Combines nine source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
ObservableSource<? extends T9> source9,
Function9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> combiner)
Combines nine source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
ObservableSource<? extends T9> source9,
Function9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> combiner)
Combines nine source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
ObservableSource<? extends T9> source9,
Function9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> combiner)
Combines nine source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
ObservableSource<? extends T9> source9,
Function9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> combiner)
Combines nine source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
ObservableSource<? extends T9> source9,
Function9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> combiner)
Combines nine source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.combineLatest(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
ObservableSource<? extends T9> source9,
Function9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> combiner)
Combines nine source ObservableSources by emitting an item that aggregates the latest values of each of the
source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T,R> Observable<R> |
Observable.combineLatestDelayError(Function<? super Object[],? extends R> combiner,
int bufferSize,
ObservableSource<? extends T>... sources)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function and delays any error from the sources until
all source ObservableSources terminate.
|
static <T,R> Observable<R> |
Observable.combineLatestDelayError(ObservableSource<? extends T>[] sources,
Function<? super Object[],? extends R> combiner)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T,R> Observable<R> |
Observable.combineLatestDelayError(ObservableSource<? extends T>[] sources,
Function<? super Object[],? extends R> combiner,
int bufferSize)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function and delays any error from the sources until
all source ObservableSources terminate.
|
static <T> Observable<T> |
Observable.concat(ObservableSource<? extends ObservableSource<? extends T>> sources)
Returns an Observable that emits the items emitted by each of the ObservableSources emitted by the source
ObservableSource, one after the other, without interleaving them.
|
static <T> Observable<T> |
Observable.concat(ObservableSource<? extends ObservableSource<? extends T>> sources,
int prefetch)
Returns an Observable that emits the items emitted by each of the ObservableSources emitted by the source
ObservableSource, one after the other, without interleaving them.
|
static <T> Observable<T> |
Single.concat(ObservableSource<? extends SingleSource<? extends T>> sources)
Concatenate the single values, in a non-overlapping fashion, of the SingleSources provided by
an Observable sequence.
|
static <T> Observable<T> |
Observable.concat(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2)
Returns an Observable that emits the items emitted by two ObservableSources, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2)
Returns an Observable that emits the items emitted by two ObservableSources, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2,
ObservableSource<? extends T> source3)
Returns an Observable that emits the items emitted by three ObservableSources, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2,
ObservableSource<? extends T> source3)
Returns an Observable that emits the items emitted by three ObservableSources, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2,
ObservableSource<? extends T> source3)
Returns an Observable that emits the items emitted by three ObservableSources, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2,
ObservableSource<? extends T> source3,
ObservableSource<? extends T> source4)
Returns an Observable that emits the items emitted by four ObservableSources, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2,
ObservableSource<? extends T> source3,
ObservableSource<? extends T> source4)
Returns an Observable that emits the items emitted by four ObservableSources, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2,
ObservableSource<? extends T> source3,
ObservableSource<? extends T> source4)
Returns an Observable that emits the items emitted by four ObservableSources, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2,
ObservableSource<? extends T> source3,
ObservableSource<? extends T> source4)
Returns an Observable that emits the items emitted by four ObservableSources, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concatArray(ObservableSource<? extends T>... sources)
Concatenates a variable number of ObservableSource sources.
|
static <T> Observable<T> |
Observable.concatArrayDelayError(ObservableSource<? extends T>... sources)
Concatenates a variable number of ObservableSource sources and delays errors from any of them
till all terminate.
|
static <T> Observable<T> |
Observable.concatArrayEager(int maxConcurrency,
int prefetch,
ObservableSource<? extends T>... sources)
Concatenates an array of ObservableSources eagerly into a single stream of values.
|
static <T> Observable<T> |
Observable.concatArrayEager(ObservableSource<? extends T>... sources)
Concatenates an array of ObservableSources eagerly into a single stream of values.
|
static <T> Observable<T> |
Observable.concatArrayEagerDelayError(int maxConcurrency,
int prefetch,
ObservableSource<? extends T>... sources)
Concatenates an array of
ObservableSource s eagerly into a single stream of values
and delaying any errors until all sources terminate. |
static <T> Observable<T> |
Observable.concatArrayEagerDelayError(ObservableSource<? extends T>... sources)
Concatenates an array of
ObservableSource s eagerly into a single stream of values
and delaying any errors until all sources terminate. |
static <T> Observable<T> |
Observable.concatDelayError(ObservableSource<? extends ObservableSource<? extends T>> sources)
Concatenates the ObservableSource sequence of ObservableSources into a single sequence by subscribing to each inner ObservableSource,
one after the other, one at a time and delays any errors till the all inner and the outer ObservableSources terminate.
|
static <T> Observable<T> |
Observable.concatDelayError(ObservableSource<? extends ObservableSource<? extends T>> sources,
int prefetch,
boolean tillTheEnd)
Concatenates the ObservableSource sequence of ObservableSources into a single sequence by subscribing to each inner ObservableSource,
one after the other, one at a time and delays any errors till the all inner and the outer ObservableSources terminate.
|
static <T> Observable<T> |
Observable.concatEager(ObservableSource<? extends ObservableSource<? extends T>> sources)
Concatenates an ObservableSource sequence of ObservableSources eagerly into a single stream of values.
|
static <T> Observable<T> |
Observable.concatEager(ObservableSource<? extends ObservableSource<? extends T>> sources,
int maxConcurrency,
int prefetch)
Concatenates an ObservableSource sequence of ObservableSources eagerly into a single stream of values.
|
Observable<T> |
Observable.concatWith(ObservableSource<? extends T> other)
Returns an Observable that emits the items emitted from the current ObservableSource, then the next, one after
the other, without interleaving them.
|
<U,V> Observable<T> |
Observable.delay(ObservableSource<U> subscriptionDelay,
Function<? super T,? extends ObservableSource<V>> itemDelay)
Returns an Observable that delays the subscription to and emissions from the source ObservableSource via another
ObservableSource on a per-item basis.
|
<U> Single<T> |
Single.delaySubscription(ObservableSource<U> other)
Delays the actual subscription to the current Single until the given other ObservableSource
signals its first value or completes.
|
<U> Observable<T> |
Observable.delaySubscription(ObservableSource<U> other)
Returns an Observable that delays the subscription to this Observable
until the other Observable emits an element or completes normally.
|
static <T> Single<T> |
Single.fromObservable(ObservableSource<? extends T> observableSource)
Wraps a specific ObservableSource into a Single and signals its single element or error.
|
static <T> Completable |
Completable.fromObservable(ObservableSource<T> observable)
Returns a Completable instance that subscribes to the given Observable, ignores all values and
emits only the terminal event.
|
<TRight,TLeftEnd,TRightEnd,R> |
Observable.groupJoin(ObservableSource<? extends TRight> other,
Function<? super T,? extends ObservableSource<TLeftEnd>> leftEnd,
Function<? super TRight,? extends ObservableSource<TRightEnd>> rightEnd,
BiFunction<? super T,? super Observable<TRight>,? extends R> resultSelector)
Returns an Observable that correlates two ObservableSources when they overlap in time and groups the results.
|
<TRight,TLeftEnd,TRightEnd,R> |
Observable.join(ObservableSource<? extends TRight> other,
Function<? super T,? extends ObservableSource<TLeftEnd>> leftEnd,
Function<? super TRight,? extends ObservableSource<TRightEnd>> rightEnd,
BiFunction<? super T,? super TRight,? extends R> resultSelector)
Correlates the items emitted by two ObservableSources based on overlapping durations.
|
static <T> Observable<T> |
Observable.merge(ObservableSource<? extends ObservableSource<? extends T>> sources)
Flattens an ObservableSource that emits ObservableSources into a single ObservableSource that emits the items emitted by
those ObservableSources, without any transformation.
|
static <T> Observable<T> |
Observable.merge(ObservableSource<? extends ObservableSource<? extends T>> sources,
int maxConcurrency)
Flattens an ObservableSource that emits ObservableSources into a single ObservableSource that emits the items emitted by
those ObservableSources, without any transformation, while limiting the maximum number of concurrent
subscriptions to these ObservableSources.
|
static <T> Observable<T> |
Observable.merge(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2)
Flattens two ObservableSources into a single ObservableSource, without any transformation.
|
static <T> Observable<T> |
Observable.merge(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2)
Flattens two ObservableSources into a single ObservableSource, without any transformation.
|
static <T> Observable<T> |
Observable.merge(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2,
ObservableSource<? extends T> source3)
Flattens three ObservableSources into a single ObservableSource, without any transformation.
|
static <T> Observable<T> |
Observable.merge(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2,
ObservableSource<? extends T> source3)
Flattens three ObservableSources into a single ObservableSource, without any transformation.
|
static <T> Observable<T> |
Observable.merge(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2,
ObservableSource<? extends T> source3)
Flattens three ObservableSources into a single ObservableSource, without any transformation.
|
static <T> Observable<T> |
Observable.merge(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2,
ObservableSource<? extends T> source3,
ObservableSource<? extends T> source4)
Flattens four ObservableSources into a single ObservableSource, without any transformation.
|
static <T> Observable<T> |
Observable.merge(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2,
ObservableSource<? extends T> source3,
ObservableSource<? extends T> source4)
Flattens four ObservableSources into a single ObservableSource, without any transformation.
|
static <T> Observable<T> |
Observable.merge(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2,
ObservableSource<? extends T> source3,
ObservableSource<? extends T> source4)
Flattens four ObservableSources into a single ObservableSource, without any transformation.
|
static <T> Observable<T> |
Observable.merge(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2,
ObservableSource<? extends T> source3,
ObservableSource<? extends T> source4)
Flattens four ObservableSources into a single ObservableSource, without any transformation.
|
static <T> Observable<T> |
Observable.mergeArray(int maxConcurrency,
int bufferSize,
ObservableSource<? extends T>... sources)
Flattens an Iterable of ObservableSources into one ObservableSource, without any transformation, while limiting the
number of concurrent subscriptions to these ObservableSources.
|
static <T> Observable<T> |
Observable.mergeArray(ObservableSource<? extends T>... sources)
Flattens an Array of ObservableSources into one ObservableSource, without any transformation.
|
static <T> Observable<T> |
Observable.mergeArrayDelayError(int maxConcurrency,
int bufferSize,
ObservableSource<? extends T>... sources)
Flattens an array of ObservableSources into one ObservableSource, in a way that allows an Observer to receive all
successfully emitted items from each of the source ObservableSources without being interrupted by an error
notification from one of them, while limiting the number of concurrent subscriptions to these ObservableSources.
|
static <T> Observable<T> |
Observable.mergeArrayDelayError(ObservableSource<? extends T>... sources)
Flattens an Iterable of ObservableSources into one ObservableSource, in a way that allows an Observer to receive all
successfully emitted items from each of the source ObservableSources without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(ObservableSource<? extends ObservableSource<? extends T>> sources)
Flattens an ObservableSource that emits ObservableSources into one ObservableSource, in a way that allows an Observer to
receive all successfully emitted items from all of the source ObservableSources without being interrupted by
an error notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(ObservableSource<? extends ObservableSource<? extends T>> sources,
int maxConcurrency)
Flattens an ObservableSource that emits ObservableSources into one ObservableSource, in a way that allows an Observer to
receive all successfully emitted items from all of the source ObservableSources without being interrupted by
an error notification from one of them, while limiting the
number of concurrent subscriptions to these ObservableSources.
|
static <T> Observable<T> |
Observable.mergeDelayError(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2)
Flattens two ObservableSources into one ObservableSource, in a way that allows an Observer to receive all
successfully emitted items from each of the source ObservableSources without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2)
Flattens two ObservableSources into one ObservableSource, in a way that allows an Observer to receive all
successfully emitted items from each of the source ObservableSources without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2,
ObservableSource<? extends T> source3)
Flattens three ObservableSources into one ObservableSource, in a way that allows an Observer to receive all
successfully emitted items from all of the source ObservableSources without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2,
ObservableSource<? extends T> source3)
Flattens three ObservableSources into one ObservableSource, in a way that allows an Observer to receive all
successfully emitted items from all of the source ObservableSources without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2,
ObservableSource<? extends T> source3)
Flattens three ObservableSources into one ObservableSource, in a way that allows an Observer to receive all
successfully emitted items from all of the source ObservableSources without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2,
ObservableSource<? extends T> source3,
ObservableSource<? extends T> source4)
Flattens four ObservableSources into one ObservableSource, in a way that allows an Observer to receive all
successfully emitted items from all of the source ObservableSources without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2,
ObservableSource<? extends T> source3,
ObservableSource<? extends T> source4)
Flattens four ObservableSources into one ObservableSource, in a way that allows an Observer to receive all
successfully emitted items from all of the source ObservableSources without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2,
ObservableSource<? extends T> source3,
ObservableSource<? extends T> source4)
Flattens four ObservableSources into one ObservableSource, in a way that allows an Observer to receive all
successfully emitted items from all of the source ObservableSources without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2,
ObservableSource<? extends T> source3,
ObservableSource<? extends T> source4)
Flattens four ObservableSources into one ObservableSource, in a way that allows an Observer to receive all
successfully emitted items from all of the source ObservableSources without being interrupted by an error
notification from one of them.
|
Observable<T> |
Observable.mergeWith(ObservableSource<? extends T> other)
Flattens this and another ObservableSource into a single ObservableSource, without any transformation.
|
Observable<T> |
Observable.onErrorResumeNext(ObservableSource<? extends T> next)
Instructs an ObservableSource to pass control to another ObservableSource rather than invoking
onError if it encounters an error. |
Observable<T> |
Observable.onExceptionResumeNext(ObservableSource<? extends T> next)
|
<U> Observable<T> |
Observable.sample(ObservableSource<U> sampler)
Returns an Observable that, when the specified
sampler ObservableSource emits an item or completes,
emits the most recently emitted item (if any) emitted by the source ObservableSource since the previous
emission from the sampler ObservableSource. |
<U> Observable<T> |
Observable.sample(ObservableSource<U> sampler,
boolean emitLast)
Returns an Observable that, when the specified
sampler ObservableSource emits an item or completes,
emits the most recently emitted item (if any) emitted by the source ObservableSource since the previous
emission from the sampler ObservableSource
and optionally emit the very last upstream item when the upstream or other ObservableSource complete. |
static <T> Single<Boolean> |
Observable.sequenceEqual(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2)
Returns a Single that emits a Boolean value that indicates whether two ObservableSource sequences are the
same by comparing the items emitted by each ObservableSource pairwise.
|
static <T> Single<Boolean> |
Observable.sequenceEqual(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2)
Returns a Single that emits a Boolean value that indicates whether two ObservableSource sequences are the
same by comparing the items emitted by each ObservableSource pairwise.
|
static <T> Single<Boolean> |
Observable.sequenceEqual(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2,
BiPredicate<? super T,? super T> isEqual)
Returns a Single that emits a Boolean value that indicates whether two ObservableSource sequences are the
same by comparing the items emitted by each ObservableSource pairwise based on the results of a specified
equality function.
|
static <T> Single<Boolean> |
Observable.sequenceEqual(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2,
BiPredicate<? super T,? super T> isEqual)
Returns a Single that emits a Boolean value that indicates whether two ObservableSource sequences are the
same by comparing the items emitted by each ObservableSource pairwise based on the results of a specified
equality function.
|
static <T> Single<Boolean> |
Observable.sequenceEqual(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2,
BiPredicate<? super T,? super T> isEqual,
int bufferSize)
Returns a Single that emits a Boolean value that indicates whether two ObservableSource sequences are the
same by comparing the items emitted by each ObservableSource pairwise based on the results of a specified
equality function.
|
static <T> Single<Boolean> |
Observable.sequenceEqual(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2,
BiPredicate<? super T,? super T> isEqual,
int bufferSize)
Returns a Single that emits a Boolean value that indicates whether two ObservableSource sequences are the
same by comparing the items emitted by each ObservableSource pairwise based on the results of a specified
equality function.
|
static <T> Single<Boolean> |
Observable.sequenceEqual(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2,
int bufferSize)
Returns a Single that emits a Boolean value that indicates whether two ObservableSource sequences are the
same by comparing the items emitted by each ObservableSource pairwise.
|
static <T> Single<Boolean> |
Observable.sequenceEqual(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2,
int bufferSize)
Returns a Single that emits a Boolean value that indicates whether two ObservableSource sequences are the
same by comparing the items emitted by each ObservableSource pairwise.
|
<U> Observable<T> |
Observable.skipUntil(ObservableSource<U> other)
Returns an Observable that skips items emitted by the source ObservableSource until a second ObservableSource emits
an item.
|
Observable<T> |
Observable.startWith(ObservableSource<? extends T> other)
Returns an Observable that emits the items in a specified
ObservableSource before it begins to emit
items emitted by the source ObservableSource. |
Observable<T> |
Observable.switchIfEmpty(ObservableSource<? extends T> other)
Returns an Observable that emits the items emitted by the source ObservableSource or the items of an alternate
ObservableSource if the source ObservableSource is empty.
|
static <T> Observable<T> |
Observable.switchOnNext(ObservableSource<? extends ObservableSource<? extends T>> sources)
Converts an ObservableSource that emits ObservableSources into an ObservableSource that emits the items emitted by the
most recently emitted of those ObservableSources.
|
static <T> Observable<T> |
Observable.switchOnNext(ObservableSource<? extends ObservableSource<? extends T>> sources,
int bufferSize)
Converts an ObservableSource that emits ObservableSources into an ObservableSource that emits the items emitted by the
most recently emitted of those ObservableSources.
|
static <T> Observable<T> |
Observable.switchOnNextDelayError(ObservableSource<? extends ObservableSource<? extends T>> sources)
Converts an ObservableSource that emits ObservableSources into an ObservableSource that emits the items emitted by the
most recently emitted of those ObservableSources and delays any exception until all ObservableSources terminate.
|
static <T> Observable<T> |
Observable.switchOnNextDelayError(ObservableSource<? extends ObservableSource<? extends T>> sources,
int prefetch)
Converts an ObservableSource that emits ObservableSources into an ObservableSource that emits the items emitted by the
most recently emitted of those ObservableSources and delays any exception until all ObservableSources terminate.
|
<U> Observable<T> |
Observable.takeUntil(ObservableSource<U> other)
Returns an Observable that emits the items emitted by the source Observable until a second ObservableSource
emits an item.
|
<V> Observable<T> |
Observable.timeout(Function<? super T,? extends ObservableSource<V>> itemTimeoutIndicator,
ObservableSource<? extends T> other)
Returns an Observable that mirrors the source ObservableSource, but that switches to a fallback ObservableSource if
an item emitted by the source ObservableSource doesn't arrive within a window of time after the emission of the
previous item, where that period of time is measured by an ObservableSource that is a function of the previous
item.
|
Observable<T> |
Observable.timeout(long timeout,
TimeUnit timeUnit,
ObservableSource<? extends T> other)
Returns an Observable that mirrors the source ObservableSource but applies a timeout policy for each emitted
item.
|
Observable<T> |
Observable.timeout(long timeout,
TimeUnit timeUnit,
Scheduler scheduler,
ObservableSource<? extends T> other)
Returns an Observable that mirrors the source ObservableSource but applies a timeout policy for each emitted
item using a specified Scheduler.
|
<U,V> Observable<T> |
Observable.timeout(ObservableSource<U> firstTimeoutIndicator,
Function<? super T,? extends ObservableSource<V>> itemTimeoutIndicator)
Returns an Observable that mirrors the source ObservableSource, but notifies observers of a
TimeoutException if either the first item emitted by the source ObservableSource or any subsequent item
doesn't arrive within time windows defined by other ObservableSources. |
<U,V> Observable<T> |
Observable.timeout(ObservableSource<U> firstTimeoutIndicator,
Function<? super T,? extends ObservableSource<V>> itemTimeoutIndicator,
ObservableSource<? extends T> other)
Returns an Observable that mirrors the source ObservableSource, but switches to a fallback ObservableSource if either
the first item emitted by the source ObservableSource or any subsequent item doesn't arrive within time windows
defined by other ObservableSources.
|
<U,V> Observable<T> |
Observable.timeout(ObservableSource<U> firstTimeoutIndicator,
Function<? super T,? extends ObservableSource<V>> itemTimeoutIndicator,
ObservableSource<? extends T> other)
Returns an Observable that mirrors the source ObservableSource, but switches to a fallback ObservableSource if either
the first item emitted by the source ObservableSource or any subsequent item doesn't arrive within time windows
defined by other ObservableSources.
|
static <T> Observable<T> |
Observable.unsafeCreate(ObservableSource<T> onSubscribe)
Create an Observable by wrapping an ObservableSource which has to be implemented according
to the Reactive-Streams-based Observable specification by handling
disposal correctly; no safeguards are provided by the Observable itself.
|
<B> Observable<Observable<T>> |
Observable.window(ObservableSource<B> boundary)
Returns an Observable that emits non-overlapping windows of items it collects from the source ObservableSource
where the boundary of each window is determined by the items emitted from a specified boundary-governing
ObservableSource.
|
<B> Observable<Observable<T>> |
Observable.window(ObservableSource<B> boundary,
int bufferSize)
Returns an Observable that emits non-overlapping windows of items it collects from the source ObservableSource
where the boundary of each window is determined by the items emitted from a specified boundary-governing
ObservableSource.
|
<U,V> Observable<Observable<T>> |
Observable.window(ObservableSource<U> openingIndicator,
Function<? super U,? extends ObservableSource<V>> closingIndicator)
Returns an Observable that emits windows of items it collects from the source ObservableSource.
|
<U,V> Observable<Observable<T>> |
Observable.window(ObservableSource<U> openingIndicator,
Function<? super U,? extends ObservableSource<V>> closingIndicator,
int bufferSize)
Returns an Observable that emits windows of items it collects from the source ObservableSource.
|
<R> Observable<R> |
Observable.withLatestFrom(ObservableSource<?>[] others,
Function<? super Object[],R> combiner)
Combines the value emission from this ObservableSource with the latest emissions from the
other ObservableSources via a function to produce the output item.
|
<U,R> Observable<R> |
Observable.withLatestFrom(ObservableSource<? extends U> other,
BiFunction<? super T,? super U,? extends R> combiner)
Merges the specified ObservableSource into this ObservableSource sequence by using the
resultSelector
function only when the source ObservableSource (this instance) emits an item. |
<T1,T2,R> Observable<R> |
Observable.withLatestFrom(ObservableSource<T1> o1,
ObservableSource<T2> o2,
Function3<? super T,? super T1,? super T2,R> combiner)
Combines the value emission from this ObservableSource with the latest emissions from the
other ObservableSources via a function to produce the output item.
|
<T1,T2,R> Observable<R> |
Observable.withLatestFrom(ObservableSource<T1> o1,
ObservableSource<T2> o2,
Function3<? super T,? super T1,? super T2,R> combiner)
Combines the value emission from this ObservableSource with the latest emissions from the
other ObservableSources via a function to produce the output item.
|
<T1,T2,T3,R> |
Observable.withLatestFrom(ObservableSource<T1> o1,
ObservableSource<T2> o2,
ObservableSource<T3> o3,
Function4<? super T,? super T1,? super T2,? super T3,R> combiner)
Combines the value emission from this ObservableSource with the latest emissions from the
other ObservableSources via a function to produce the output item.
|
<T1,T2,T3,R> |
Observable.withLatestFrom(ObservableSource<T1> o1,
ObservableSource<T2> o2,
ObservableSource<T3> o3,
Function4<? super T,? super T1,? super T2,? super T3,R> combiner)
Combines the value emission from this ObservableSource with the latest emissions from the
other ObservableSources via a function to produce the output item.
|
<T1,T2,T3,R> |
Observable.withLatestFrom(ObservableSource<T1> o1,
ObservableSource<T2> o2,
ObservableSource<T3> o3,
Function4<? super T,? super T1,? super T2,? super T3,R> combiner)
Combines the value emission from this ObservableSource with the latest emissions from the
other ObservableSources via a function to produce the output item.
|
<T1,T2,T3,T4,R> |
Observable.withLatestFrom(ObservableSource<T1> o1,
ObservableSource<T2> o2,
ObservableSource<T3> o3,
ObservableSource<T4> o4,
Function5<? super T,? super T1,? super T2,? super T3,? super T4,R> combiner)
Combines the value emission from this ObservableSource with the latest emissions from the
other ObservableSources via a function to produce the output item.
|
<T1,T2,T3,T4,R> |
Observable.withLatestFrom(ObservableSource<T1> o1,
ObservableSource<T2> o2,
ObservableSource<T3> o3,
ObservableSource<T4> o4,
Function5<? super T,? super T1,? super T2,? super T3,? super T4,R> combiner)
Combines the value emission from this ObservableSource with the latest emissions from the
other ObservableSources via a function to produce the output item.
|
<T1,T2,T3,T4,R> |
Observable.withLatestFrom(ObservableSource<T1> o1,
ObservableSource<T2> o2,
ObservableSource<T3> o3,
ObservableSource<T4> o4,
Function5<? super T,? super T1,? super T2,? super T3,? super T4,R> combiner)
Combines the value emission from this ObservableSource with the latest emissions from the
other ObservableSources via a function to produce the output item.
|
<T1,T2,T3,T4,R> |
Observable.withLatestFrom(ObservableSource<T1> o1,
ObservableSource<T2> o2,
ObservableSource<T3> o3,
ObservableSource<T4> o4,
Function5<? super T,? super T1,? super T2,? super T3,? super T4,R> combiner)
Combines the value emission from this ObservableSource with the latest emissions from the
other ObservableSources via a function to produce the output item.
|
static <T> Observable<T> |
Observable.wrap(ObservableSource<T> source)
Wraps an ObservableSource into an Observable if not already an Observable.
|
static <T,R> Observable<R> |
Observable.zip(ObservableSource<? extends ObservableSource<? extends T>> sources,
Function<? super Object[],? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
n items emitted, in sequence, by the n ObservableSources emitted by a specified ObservableSource.
|
static <T1,T2,R> Observable<R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
BiFunction<? super T1,? super T2,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
two items emitted, in sequence, by two other ObservableSources.
|
static <T1,T2,R> Observable<R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
BiFunction<? super T1,? super T2,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
two items emitted, in sequence, by two other ObservableSources.
|
static <T1,T2,R> Observable<R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
BiFunction<? super T1,? super T2,? extends R> zipper,
boolean delayError)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
two items emitted, in sequence, by two other ObservableSources.
|
static <T1,T2,R> Observable<R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
BiFunction<? super T1,? super T2,? extends R> zipper,
boolean delayError)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
two items emitted, in sequence, by two other ObservableSources.
|
static <T1,T2,R> Observable<R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
BiFunction<? super T1,? super T2,? extends R> zipper,
boolean delayError,
int bufferSize)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
two items emitted, in sequence, by two other ObservableSources.
|
static <T1,T2,R> Observable<R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
BiFunction<? super T1,? super T2,? extends R> zipper,
boolean delayError,
int bufferSize)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
two items emitted, in sequence, by two other ObservableSources.
|
static <T1,T2,T3,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
Function3<? super T1,? super T2,? super T3,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
three items emitted, in sequence, by three other ObservableSources.
|
static <T1,T2,T3,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
Function3<? super T1,? super T2,? super T3,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
three items emitted, in sequence, by three other ObservableSources.
|
static <T1,T2,T3,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
Function3<? super T1,? super T2,? super T3,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
three items emitted, in sequence, by three other ObservableSources.
|
static <T1,T2,T3,T4,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
Function4<? super T1,? super T2,? super T3,? super T4,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
four items emitted, in sequence, by four other ObservableSources.
|
static <T1,T2,T3,T4,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
Function4<? super T1,? super T2,? super T3,? super T4,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
four items emitted, in sequence, by four other ObservableSources.
|
static <T1,T2,T3,T4,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
Function4<? super T1,? super T2,? super T3,? super T4,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
four items emitted, in sequence, by four other ObservableSources.
|
static <T1,T2,T3,T4,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
Function4<? super T1,? super T2,? super T3,? super T4,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
four items emitted, in sequence, by four other ObservableSources.
|
static <T1,T2,T3,T4,T5,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
Function5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
five items emitted, in sequence, by five other ObservableSources.
|
static <T1,T2,T3,T4,T5,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
Function5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
five items emitted, in sequence, by five other ObservableSources.
|
static <T1,T2,T3,T4,T5,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
Function5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
five items emitted, in sequence, by five other ObservableSources.
|
static <T1,T2,T3,T4,T5,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
Function5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
five items emitted, in sequence, by five other ObservableSources.
|
static <T1,T2,T3,T4,T5,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
Function5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
five items emitted, in sequence, by five other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
Function6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
six items emitted, in sequence, by six other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
Function6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
six items emitted, in sequence, by six other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
Function6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
six items emitted, in sequence, by six other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
Function6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
six items emitted, in sequence, by six other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
Function6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
six items emitted, in sequence, by six other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
Function6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
six items emitted, in sequence, by six other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
Function7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
seven items emitted, in sequence, by seven other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
Function7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
seven items emitted, in sequence, by seven other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
Function7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
seven items emitted, in sequence, by seven other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
Function7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
seven items emitted, in sequence, by seven other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
Function7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
seven items emitted, in sequence, by seven other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
Function7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
seven items emitted, in sequence, by seven other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
Function7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
seven items emitted, in sequence, by seven other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
Function8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
eight items emitted, in sequence, by eight other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
Function8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
eight items emitted, in sequence, by eight other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
Function8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
eight items emitted, in sequence, by eight other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
Function8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
eight items emitted, in sequence, by eight other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
Function8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
eight items emitted, in sequence, by eight other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
Function8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
eight items emitted, in sequence, by eight other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
Function8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
eight items emitted, in sequence, by eight other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
Function8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
eight items emitted, in sequence, by eight other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
ObservableSource<? extends T9> source9,
Function9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
nine items emitted, in sequence, by nine other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
ObservableSource<? extends T9> source9,
Function9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
nine items emitted, in sequence, by nine other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
ObservableSource<? extends T9> source9,
Function9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
nine items emitted, in sequence, by nine other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
ObservableSource<? extends T9> source9,
Function9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
nine items emitted, in sequence, by nine other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
ObservableSource<? extends T9> source9,
Function9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
nine items emitted, in sequence, by nine other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
ObservableSource<? extends T9> source9,
Function9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
nine items emitted, in sequence, by nine other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
ObservableSource<? extends T9> source9,
Function9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
nine items emitted, in sequence, by nine other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
ObservableSource<? extends T9> source9,
Function9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
nine items emitted, in sequence, by nine other ObservableSources.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.zip(ObservableSource<? extends T1> source1,
ObservableSource<? extends T2> source2,
ObservableSource<? extends T3> source3,
ObservableSource<? extends T4> source4,
ObservableSource<? extends T5> source5,
ObservableSource<? extends T6> source6,
ObservableSource<? extends T7> source7,
ObservableSource<? extends T8> source8,
ObservableSource<? extends T9> source9,
Function9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
nine items emitted, in sequence, by nine other ObservableSources.
|
static <T,R> Observable<R> |
Observable.zipArray(Function<? super Object[],? extends R> zipper,
boolean delayError,
int bufferSize,
ObservableSource<? extends T>... sources)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
items emitted, in sequence, by an array of other ObservableSources.
|
<U,R> Observable<R> |
Observable.zipWith(ObservableSource<? extends U> other,
BiFunction<? super T,? super U,? extends R> zipper)
Returns an Observable that emits items that are the result of applying a specified function to pairs of
values, one each from the source ObservableSource and another specified ObservableSource.
|
<U,R> Observable<R> |
Observable.zipWith(ObservableSource<? extends U> other,
BiFunction<? super T,? super U,? extends R> zipper,
boolean delayError)
Returns an Observable that emits items that are the result of applying a specified function to pairs of
values, one each from the source ObservableSource and another specified ObservableSource.
|
<U,R> Observable<R> |
Observable.zipWith(ObservableSource<? extends U> other,
BiFunction<? super T,? super U,? extends R> zipper,
boolean delayError,
int bufferSize)
Returns an Observable that emits items that are the result of applying a specified function to pairs of
values, one each from the source ObservableSource and another specified ObservableSource.
|
Modifier and Type | Method and Description |
---|---|
static <T> Observable<T> |
Observable.amb(Iterable<? extends ObservableSource<? extends T>> sources)
Mirrors the one ObservableSource in an Iterable of several ObservableSources that first either emits an item or sends
a termination notification.
|
<B> Observable<List<T>> |
Observable.buffer(Callable<? extends ObservableSource<B>> boundarySupplier)
Returns an Observable that emits buffers of items it collects from the source ObservableSource.
|
<B,U extends Collection<? super T>> |
Observable.buffer(Callable<? extends ObservableSource<B>> boundarySupplier,
Callable<U> bufferSupplier)
Returns an Observable that emits buffers of items it collects from the source ObservableSource.
|
<TOpening,TClosing> |
Observable.buffer(ObservableSource<? extends TOpening> openingIndicator,
Function<? super TOpening,? extends ObservableSource<? extends TClosing>> closingIndicator)
Returns an Observable that emits buffers of items it collects from the source ObservableSource.
|
<TOpening,TClosing,U extends Collection<? super T>> |
Observable.buffer(ObservableSource<? extends TOpening> openingIndicator,
Function<? super TOpening,? extends ObservableSource<? extends TClosing>> closingIndicator,
Callable<U> bufferSupplier)
Returns an Observable that emits buffers of items it collects from the source ObservableSource.
|
static <T,R> Observable<R> |
Observable.combineLatest(Iterable<? extends ObservableSource<? extends T>> sources,
Function<? super Object[],? extends R> combiner)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T,R> Observable<R> |
Observable.combineLatest(Iterable<? extends ObservableSource<? extends T>> sources,
Function<? super Object[],? extends R> combiner,
int bufferSize)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T,R> Observable<R> |
Observable.combineLatestDelayError(Iterable<? extends ObservableSource<? extends T>> sources,
Function<? super Object[],? extends R> combiner)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function and delays any error from the sources until
all source ObservableSources terminate.
|
static <T,R> Observable<R> |
Observable.combineLatestDelayError(Iterable<? extends ObservableSource<? extends T>> sources,
Function<? super Object[],? extends R> combiner,
int bufferSize)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function and delays any error from the sources until
all source ObservableSources terminate.
|
static <T> Observable<T> |
Observable.concat(Iterable<? extends ObservableSource<? extends T>> sources)
Concatenates elements of each ObservableSource provided via an Iterable sequence into a single sequence
of elements without interleaving them.
|
static <T> Observable<T> |
Observable.concat(ObservableSource<? extends ObservableSource<? extends T>> sources)
Returns an Observable that emits the items emitted by each of the ObservableSources emitted by the source
ObservableSource, one after the other, without interleaving them.
|
static <T> Observable<T> |
Observable.concat(ObservableSource<? extends ObservableSource<? extends T>> sources,
int prefetch)
Returns an Observable that emits the items emitted by each of the ObservableSources emitted by the source
ObservableSource, one after the other, without interleaving them.
|
static <T> Observable<T> |
Observable.concatDelayError(Iterable<? extends ObservableSource<? extends T>> sources)
Concatenates the Iterable sequence of ObservableSources into a single sequence by subscribing to each ObservableSource,
one after the other, one at a time and delays any errors till the all inner ObservableSources terminate.
|
static <T> Observable<T> |
Observable.concatDelayError(ObservableSource<? extends ObservableSource<? extends T>> sources)
Concatenates the ObservableSource sequence of ObservableSources into a single sequence by subscribing to each inner ObservableSource,
one after the other, one at a time and delays any errors till the all inner and the outer ObservableSources terminate.
|
static <T> Observable<T> |
Observable.concatDelayError(ObservableSource<? extends ObservableSource<? extends T>> sources,
int prefetch,
boolean tillTheEnd)
Concatenates the ObservableSource sequence of ObservableSources into a single sequence by subscribing to each inner ObservableSource,
one after the other, one at a time and delays any errors till the all inner and the outer ObservableSources terminate.
|
static <T> Observable<T> |
Observable.concatEager(Iterable<? extends ObservableSource<? extends T>> sources)
Concatenates a sequence of ObservableSources eagerly into a single stream of values.
|
static <T> Observable<T> |
Observable.concatEager(Iterable<? extends ObservableSource<? extends T>> sources,
int maxConcurrency,
int prefetch)
Concatenates a sequence of ObservableSources eagerly into a single stream of values.
|
static <T> Observable<T> |
Observable.concatEager(ObservableSource<? extends ObservableSource<? extends T>> sources)
Concatenates an ObservableSource sequence of ObservableSources eagerly into a single stream of values.
|
static <T> Observable<T> |
Observable.concatEager(ObservableSource<? extends ObservableSource<? extends T>> sources,
int maxConcurrency,
int prefetch)
Concatenates an ObservableSource sequence of ObservableSources eagerly into a single stream of values.
|
<R> Observable<R> |
Observable.concatMap(Function<? super T,? extends ObservableSource<? extends R>> mapper)
Returns a new Observable that emits items resulting from applying a function that you supply to each item
emitted by the source ObservableSource, where that function returns an ObservableSource, and then emitting the items
that result from concatenating those resulting ObservableSources.
|
<R> Observable<R> |
Observable.concatMap(Function<? super T,? extends ObservableSource<? extends R>> mapper,
int prefetch)
Returns a new Observable that emits items resulting from applying a function that you supply to each item
emitted by the source ObservableSource, where that function returns an ObservableSource, and then emitting the items
that result from concatenating those resulting ObservableSources.
|
<R> Observable<R> |
Observable.concatMapDelayError(Function<? super T,? extends ObservableSource<? extends R>> mapper)
Maps each of the items into an ObservableSource, 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 inner ObservableSources
till all of them terminate.
|
<R> Observable<R> |
Observable.concatMapDelayError(Function<? super T,? extends ObservableSource<? extends R>> mapper,
int prefetch,
boolean tillTheEnd)
Maps each of the items into an ObservableSource, 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 inner ObservableSources
till all of them terminate.
|
<R> Observable<R> |
Observable.concatMapEager(Function<? super T,? extends ObservableSource<? extends R>> mapper)
Maps a sequence of values into ObservableSources and concatenates these ObservableSources eagerly into a single
ObservableSource.
|
<R> Observable<R> |
Observable.concatMapEager(Function<? super T,? extends ObservableSource<? extends R>> mapper,
int maxConcurrency,
int prefetch)
Maps a sequence of values into ObservableSources and concatenates these ObservableSources eagerly into a single
ObservableSource.
|
<R> Observable<R> |
Observable.concatMapEagerDelayError(Function<? super T,? extends ObservableSource<? extends R>> mapper,
boolean tillTheEnd)
Maps a sequence of values into ObservableSources and concatenates these ObservableSources eagerly into a single
ObservableSource.
|
<R> Observable<R> |
Observable.concatMapEagerDelayError(Function<? super T,? extends ObservableSource<? extends R>> mapper,
int maxConcurrency,
int prefetch,
boolean tillTheEnd)
Maps a sequence of values into ObservableSources and concatenates these ObservableSources eagerly into a single
ObservableSource.
|
<U> Observable<T> |
Observable.debounce(Function<? super T,? extends ObservableSource<U>> debounceSelector)
Returns an Observable that mirrors the source ObservableSource, except that it drops items emitted by the
source ObservableSource that are followed by another item within a computed debounce duration.
|
static <T> Observable<T> |
Observable.defer(Callable<? extends ObservableSource<? extends T>> supplier)
Returns an Observable that calls an ObservableSource factory to create an ObservableSource for each new Observer
that subscribes.
|
<U> Observable<T> |
Observable.delay(Function<? super T,? extends ObservableSource<U>> itemDelay)
Returns an Observable that delays the emissions of the source ObservableSource via another ObservableSource on a
per-item basis.
|
<U,V> Observable<T> |
Observable.delay(ObservableSource<U> subscriptionDelay,
Function<? super T,? extends ObservableSource<V>> itemDelay)
Returns an Observable that delays the subscription to and emissions from the source ObservableSource via another
ObservableSource on a per-item basis.
|
<R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends R>> mapper)
Returns an Observable that emits items based on applying a function that you supply to each item emitted
by the source ObservableSource, where that function returns an ObservableSource, and then merging those resulting
ObservableSources and emitting the results of this merger.
|
<R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends R>> mapper,
boolean delayErrors)
Returns an Observable that emits items based on applying a function that you supply to each item emitted
by the source ObservableSource, where that function returns an ObservableSource, and then merging those resulting
ObservableSources and emitting the results of this merger.
|
<R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends R>> mapper,
boolean delayErrors,
int maxConcurrency)
Returns an Observable that emits items based on applying a function that you supply to each item emitted
by the source ObservableSource, where that function returns an ObservableSource, and then merging those resulting
ObservableSources and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these ObservableSources.
|
<R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends R>> mapper,
boolean delayErrors,
int maxConcurrency,
int bufferSize)
Returns an Observable that emits items based on applying a function that you supply to each item emitted
by the source ObservableSource, where that function returns an ObservableSource, and then merging those resulting
ObservableSources and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these ObservableSources.
|
<R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends R>> onNextMapper,
Function<? super Throwable,? extends ObservableSource<? extends R>> onErrorMapper,
Callable<? extends ObservableSource<? extends R>> onCompleteSupplier)
Returns an Observable that applies a function to each item emitted or notification raised by the source
ObservableSource and then flattens the ObservableSources returned from these functions and emits the resulting items.
|
<R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends R>> onNextMapper,
Function<? super Throwable,? extends ObservableSource<? extends R>> onErrorMapper,
Callable<? extends ObservableSource<? extends R>> onCompleteSupplier)
Returns an Observable that applies a function to each item emitted or notification raised by the source
ObservableSource and then flattens the ObservableSources returned from these functions and emits the resulting items.
|
<R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends R>> onNextMapper,
Function<? super Throwable,? extends ObservableSource<? extends R>> onErrorMapper,
Callable<? extends ObservableSource<? extends R>> onCompleteSupplier)
Returns an Observable that applies a function to each item emitted or notification raised by the source
ObservableSource and then flattens the ObservableSources returned from these functions and emits the resulting items.
|
<R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends R>> onNextMapper,
Function<Throwable,? extends ObservableSource<? extends R>> onErrorMapper,
Callable<? extends ObservableSource<? extends R>> onCompleteSupplier,
int maxConcurrency)
Returns an Observable that applies a function to each item emitted or notification raised by the source
ObservableSource and then flattens the ObservableSources returned from these functions and emits the resulting items,
while limiting the maximum number of concurrent subscriptions to these ObservableSources.
|
<R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends R>> onNextMapper,
Function<Throwable,? extends ObservableSource<? extends R>> onErrorMapper,
Callable<? extends ObservableSource<? extends R>> onCompleteSupplier,
int maxConcurrency)
Returns an Observable that applies a function to each item emitted or notification raised by the source
ObservableSource and then flattens the ObservableSources returned from these functions and emits the resulting items,
while limiting the maximum number of concurrent subscriptions to these ObservableSources.
|
<R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends R>> onNextMapper,
Function<Throwable,? extends ObservableSource<? extends R>> onErrorMapper,
Callable<? extends ObservableSource<? extends R>> onCompleteSupplier,
int maxConcurrency)
Returns an Observable that applies a function to each item emitted or notification raised by the source
ObservableSource and then flattens the ObservableSources returned from these functions and emits the resulting items,
while limiting the maximum number of concurrent subscriptions to these ObservableSources.
|
<R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends R>> mapper,
int maxConcurrency)
Returns an Observable that emits items based on applying a function that you supply to each item emitted
by the source ObservableSource, where that function returns an ObservableSource, and then merging those resulting
ObservableSources and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these ObservableSources.
|
<U,R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends U>> mapper,
BiFunction<? super T,? super U,? extends R> resultSelector)
Returns an Observable that emits the results of a specified function to the pair of values emitted by the
source ObservableSource and a specified collection ObservableSource.
|
<U,R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends U>> mapper,
BiFunction<? super T,? super U,? extends R> combiner,
boolean delayErrors)
Returns an Observable that emits the results of a specified function to the pair of values emitted by the
source ObservableSource and a specified collection ObservableSource.
|
<U,R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends U>> mapper,
BiFunction<? super T,? super U,? extends R> combiner,
boolean delayErrors,
int maxConcurrency)
Returns an Observable that emits the results of a specified function to the pair of values emitted by the
source ObservableSource and a specified collection ObservableSource, while limiting the maximum number of concurrent
subscriptions to these ObservableSources.
|
<U,R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends U>> mapper,
BiFunction<? super T,? super U,? extends R> combiner,
boolean delayErrors,
int maxConcurrency,
int bufferSize)
Returns an Observable that emits the results of a specified function to the pair of values emitted by the
source ObservableSource and a specified collection ObservableSource, while limiting the maximum number of concurrent
subscriptions to these ObservableSources.
|
<U,R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends U>> mapper,
BiFunction<? super T,? super U,? extends R> combiner,
int maxConcurrency)
Returns an Observable that emits the results of a specified function to the pair of values emitted by the
source ObservableSource and a specified collection ObservableSource, while limiting the maximum number of concurrent
subscriptions to these ObservableSources.
|
<R> Observable<R> |
Single.flatMapObservable(Function<? super T,? extends ObservableSource<? extends R>> mapper)
Returns an Observable that is based on applying a specified function to the item emitted by the source Single,
where that function returns an ObservableSource.
|
<R> Observable<R> |
Maybe.flatMapObservable(Function<? super T,? extends ObservableSource<? extends R>> mapper)
Returns an Observable that is based on applying a specified function to the item emitted by the source Maybe,
where that function returns an ObservableSource.
|
<TRight,TLeftEnd,TRightEnd,R> |
Observable.groupJoin(ObservableSource<? extends TRight> other,
Function<? super T,? extends ObservableSource<TLeftEnd>> leftEnd,
Function<? super TRight,? extends ObservableSource<TRightEnd>> rightEnd,
BiFunction<? super T,? super Observable<TRight>,? extends R> resultSelector)
Returns an Observable that correlates two ObservableSources when they overlap in time and groups the results.
|
<TRight,TLeftEnd,TRightEnd,R> |
Observable.groupJoin(ObservableSource<? extends TRight> other,
Function<? super T,? extends ObservableSource<TLeftEnd>> leftEnd,
Function<? super TRight,? extends ObservableSource<TRightEnd>> rightEnd,
BiFunction<? super T,? super Observable<TRight>,? extends R> resultSelector)
Returns an Observable that correlates two ObservableSources when they overlap in time and groups the results.
|
<TRight,TLeftEnd,TRightEnd,R> |
Observable.join(ObservableSource<? extends TRight> other,
Function<? super T,? extends ObservableSource<TLeftEnd>> leftEnd,
Function<? super TRight,? extends ObservableSource<TRightEnd>> rightEnd,
BiFunction<? super T,? super TRight,? extends R> resultSelector)
Correlates the items emitted by two ObservableSources based on overlapping durations.
|
<TRight,TLeftEnd,TRightEnd,R> |
Observable.join(ObservableSource<? extends TRight> other,
Function<? super T,? extends ObservableSource<TLeftEnd>> leftEnd,
Function<? super TRight,? extends ObservableSource<TRightEnd>> rightEnd,
BiFunction<? super T,? super TRight,? extends R> resultSelector)
Correlates the items emitted by two ObservableSources based on overlapping durations.
|
static <T> Observable<T> |
Observable.merge(Iterable<? extends ObservableSource<? extends T>> sources)
Flattens an Iterable of ObservableSources into one ObservableSource, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Iterable<? extends ObservableSource<? extends T>> sources,
int maxConcurrency)
Flattens an Iterable of ObservableSources into one ObservableSource, without any transformation, while limiting the
number of concurrent subscriptions to these ObservableSources.
|
static <T> Observable<T> |
Observable.merge(Iterable<? extends ObservableSource<? extends T>> sources,
int maxConcurrency,
int bufferSize)
Flattens an Iterable of ObservableSources into one ObservableSource, without any transformation, while limiting the
number of concurrent subscriptions to these ObservableSources.
|
static <T> Observable<T> |
Observable.merge(ObservableSource<? extends ObservableSource<? extends T>> sources)
Flattens an ObservableSource that emits ObservableSources into a single ObservableSource that emits the items emitted by
those ObservableSources, without any transformation.
|
static <T> Observable<T> |
Observable.merge(ObservableSource<? extends ObservableSource<? extends T>> sources,
int maxConcurrency)
Flattens an ObservableSource that emits ObservableSources into a single ObservableSource that emits the items emitted by
those ObservableSources, without any transformation, while limiting the maximum number of concurrent
subscriptions to these ObservableSources.
|
static <T> Observable<T> |
Observable.mergeDelayError(Iterable<? extends ObservableSource<? extends T>> sources)
Flattens an Iterable of ObservableSources into one ObservableSource, in a way that allows an Observer to receive all
successfully emitted items from each of the source ObservableSources without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Iterable<? extends ObservableSource<? extends T>> sources,
int maxConcurrency)
Flattens an Iterable of ObservableSources into one ObservableSource, in a way that allows an Observer to receive all
successfully emitted items from each of the source ObservableSources without being interrupted by an error
notification from one of them, while limiting the number of concurrent subscriptions to these ObservableSources.
|
static <T> Observable<T> |
Observable.mergeDelayError(Iterable<? extends ObservableSource<? extends T>> sources,
int maxConcurrency,
int bufferSize)
Flattens an Iterable of ObservableSources into one ObservableSource, in a way that allows an Observer to receive all
successfully emitted items from each of the source ObservableSources without being interrupted by an error
notification from one of them, while limiting the number of concurrent subscriptions to these ObservableSources.
|
static <T> Observable<T> |
Observable.mergeDelayError(ObservableSource<? extends ObservableSource<? extends T>> sources)
Flattens an ObservableSource that emits ObservableSources into one ObservableSource, in a way that allows an Observer to
receive all successfully emitted items from all of the source ObservableSources without being interrupted by
an error notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(ObservableSource<? extends ObservableSource<? extends T>> sources,
int maxConcurrency)
Flattens an ObservableSource that emits ObservableSources into one ObservableSource, in a way that allows an Observer to
receive all successfully emitted items from all of the source ObservableSources without being interrupted by
an error notification from one of them, while limiting the
number of concurrent subscriptions to these ObservableSources.
|
Observable<T> |
Observable.onErrorResumeNext(Function<? super Throwable,? extends ObservableSource<? extends T>> resumeFunction)
Instructs an ObservableSource to pass control to another ObservableSource rather than invoking
onError if it encounters an error. |
<R> Observable<R> |
Observable.publish(Function<? super Observable<T>,? extends ObservableSource<R>> selector)
Returns an Observable that emits the results of invoking a specified selector on items emitted by a
ConnectableObservable that shares a single subscription to the underlying sequence. |
Observable<T> |
Observable.repeatWhen(Function<? super Observable<Object>,? extends ObservableSource<?>> handler)
Returns an Observable that emits the same values as the source ObservableSource with the exception of an
onComplete . |
<R> Observable<R> |
Observable.replay(Function<? super Observable<T>,? extends ObservableSource<R>> selector)
Returns an Observable that emits items that are the results of invoking a specified selector on the items
emitted by a
ConnectableObservable that shares a single subscription to the source ObservableSource. |
<R> Observable<R> |
Observable.replay(Function<? super Observable<T>,? extends ObservableSource<R>> selector,
int bufferSize)
Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a
ConnectableObservable that shares a single subscription to the source ObservableSource,
replaying bufferSize notifications. |
<R> Observable<R> |
Observable.replay(Function<? super Observable<T>,? extends ObservableSource<R>> selector,
int bufferSize,
long time,
TimeUnit unit)
Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a
ConnectableObservable that shares a single subscription to the source ObservableSource,
replaying no more than bufferSize items that were emitted within a specified time window. |
<R> Observable<R> |
Observable.replay(Function<? super Observable<T>,? extends ObservableSource<R>> selector,
int bufferSize,
long time,
TimeUnit unit,
Scheduler scheduler)
Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a
ConnectableObservable that shares a single subscription to the source ObservableSource,
replaying no more than bufferSize items that were emitted within a specified time window. |
<R> Observable<R> |
Observable.replay(Function<? super Observable<T>,? extends ObservableSource<R>> selector,
int bufferSize,
Scheduler scheduler)
Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a
ConnectableObservable that shares a single subscription to the source ObservableSource,
replaying a maximum of bufferSize items. |
<R> Observable<R> |
Observable.replay(Function<? super Observable<T>,? extends ObservableSource<R>> selector,
long time,
TimeUnit unit)
Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a
ConnectableObservable that shares a single subscription to the source ObservableSource,
replaying all items that were emitted within a specified time window. |
<R> Observable<R> |
Observable.replay(Function<? super Observable<T>,? extends ObservableSource<R>> selector,
long time,
TimeUnit unit,
Scheduler scheduler)
Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a
ConnectableObservable that shares a single subscription to the source ObservableSource,
replaying all items that were emitted within a specified time window. |
<R> Observable<R> |
Observable.replay(Function<? super Observable<T>,? extends ObservableSource<R>> selector,
Scheduler scheduler)
Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a
ConnectableObservable that shares a single subscription to the source ObservableSource. |
Observable<T> |
Observable.retryWhen(Function<? super Observable<Throwable>,? extends ObservableSource<?>> handler)
Returns an Observable that emits the same values as the source ObservableSource with the exception of an
onError . |
<R> Observable<R> |
Observable.switchMap(Function<? super T,? extends ObservableSource<? extends R>> mapper)
Returns a new ObservableSource by applying a function that you supply to each item emitted by the source
ObservableSource that returns an ObservableSource, and then emitting the items emitted by the most recently emitted
of these ObservableSources.
|
<R> Observable<R> |
Observable.switchMap(Function<? super T,? extends ObservableSource<? extends R>> mapper,
int bufferSize)
Returns a new ObservableSource by applying a function that you supply to each item emitted by the source
ObservableSource that returns an ObservableSource, and then emitting the items emitted by the most recently emitted
of these ObservableSources.
|
<R> Observable<R> |
Observable.switchMapDelayError(Function<? super T,? extends ObservableSource<? extends R>> mapper)
Returns a new ObservableSource by applying a function that you supply to each item emitted by the source
ObservableSource that returns an ObservableSource, and then emitting the items emitted by the most recently emitted
of these ObservableSources and delays any error until all ObservableSources terminate.
|
<R> Observable<R> |
Observable.switchMapDelayError(Function<? super T,? extends ObservableSource<? extends R>> mapper,
int bufferSize)
Returns a new ObservableSource by applying a function that you supply to each item emitted by the source
ObservableSource that returns an ObservableSource, and then emitting the items emitted by the most recently emitted
of these ObservableSources and delays any error until all ObservableSources terminate.
|
static <T> Observable<T> |
Observable.switchOnNext(ObservableSource<? extends ObservableSource<? extends T>> sources)
Converts an ObservableSource that emits ObservableSources into an ObservableSource that emits the items emitted by the
most recently emitted of those ObservableSources.
|
static <T> Observable<T> |
Observable.switchOnNext(ObservableSource<? extends ObservableSource<? extends T>> sources,
int bufferSize)
Converts an ObservableSource that emits ObservableSources into an ObservableSource that emits the items emitted by the
most recently emitted of those ObservableSources.
|
static <T> Observable<T> |
Observable.switchOnNextDelayError(ObservableSource<? extends ObservableSource<? extends T>> sources)
Converts an ObservableSource that emits ObservableSources into an ObservableSource that emits the items emitted by the
most recently emitted of those ObservableSources and delays any exception until all ObservableSources terminate.
|
static <T> Observable<T> |
Observable.switchOnNextDelayError(ObservableSource<? extends ObservableSource<? extends T>> sources,
int prefetch)
Converts an ObservableSource that emits ObservableSources into an ObservableSource that emits the items emitted by the
most recently emitted of those ObservableSources and delays any exception until all ObservableSources terminate.
|
<V> Observable<T> |
Observable.timeout(Function<? super T,? extends ObservableSource<V>> itemTimeoutIndicator)
Returns an Observable that mirrors the source ObservableSource, but notifies observers of a
TimeoutException if an item emitted by the source ObservableSource doesn't arrive within a window of
time after the emission of the previous item, where that period of time is measured by an ObservableSource that
is a function of the previous item. |
<V> Observable<T> |
Observable.timeout(Function<? super T,? extends ObservableSource<V>> itemTimeoutIndicator,
ObservableSource<? extends T> other)
Returns an Observable that mirrors the source ObservableSource, but that switches to a fallback ObservableSource if
an item emitted by the source ObservableSource doesn't arrive within a window of time after the emission of the
previous item, where that period of time is measured by an ObservableSource that is a function of the previous
item.
|
<U,V> Observable<T> |
Observable.timeout(ObservableSource<U> firstTimeoutIndicator,
Function<? super T,? extends ObservableSource<V>> itemTimeoutIndicator)
Returns an Observable that mirrors the source ObservableSource, but notifies observers of a
TimeoutException if either the first item emitted by the source ObservableSource or any subsequent item
doesn't arrive within time windows defined by other ObservableSources. |
<U,V> Observable<T> |
Observable.timeout(ObservableSource<U> firstTimeoutIndicator,
Function<? super T,? extends ObservableSource<V>> itemTimeoutIndicator,
ObservableSource<? extends T> other)
Returns an Observable that mirrors the source ObservableSource, but switches to a fallback ObservableSource if either
the first item emitted by the source ObservableSource or any subsequent item doesn't arrive within time windows
defined by other ObservableSources.
|
static <T,D> Observable<T> |
Observable.using(Callable<? extends D> resourceSupplier,
Function<? super D,? extends ObservableSource<? extends T>> sourceSupplier,
Consumer<? super D> disposer)
Constructs an ObservableSource that creates a dependent resource object which is disposed of when the downstream
calls dispose().
|
static <T,D> Observable<T> |
Observable.using(Callable<? extends D> resourceSupplier,
Function<? super D,? extends ObservableSource<? extends T>> sourceSupplier,
Consumer<? super D> disposer,
boolean eager)
Constructs an ObservableSource that creates a dependent resource object which is disposed of just before
termination if you have set
disposeEagerly to true and a dispose() call does not occur
before termination. |
<B> Observable<Observable<T>> |
Observable.window(Callable<? extends ObservableSource<B>> boundary)
Returns an Observable that emits windows of items it collects from the source ObservableSource.
|
<B> Observable<Observable<T>> |
Observable.window(Callable<? extends ObservableSource<B>> boundary,
int bufferSize)
Returns an Observable that emits windows of items it collects from the source ObservableSource.
|
<U,V> Observable<Observable<T>> |
Observable.window(ObservableSource<U> openingIndicator,
Function<? super U,? extends ObservableSource<V>> closingIndicator)
Returns an Observable that emits windows of items it collects from the source ObservableSource.
|
<U,V> Observable<Observable<T>> |
Observable.window(ObservableSource<U> openingIndicator,
Function<? super U,? extends ObservableSource<V>> closingIndicator,
int bufferSize)
Returns an Observable that emits windows of items it collects from the source ObservableSource.
|
<R> Observable<R> |
Observable.withLatestFrom(Iterable<? extends ObservableSource<?>> others,
Function<? super Object[],R> combiner)
Combines the value emission from this ObservableSource with the latest emissions from the
other ObservableSources via a function to produce the output item.
|
static <T,R> Observable<R> |
Observable.zip(Iterable<? extends ObservableSource<? extends T>> sources,
Function<? super Object[],? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
items emitted, in sequence, by an Iterable of other ObservableSources.
|
static <T,R> Observable<R> |
Observable.zip(ObservableSource<? extends ObservableSource<? extends T>> sources,
Function<? super Object[],? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
n items emitted, in sequence, by the n ObservableSources emitted by a specified ObservableSource.
|
static <T,R> Observable<R> |
Observable.zipIterable(Iterable<? extends ObservableSource<? extends T>> sources,
Function<? super Object[],? extends R> zipper,
boolean delayError,
int bufferSize)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
items emitted, in sequence, by an Iterable of other ObservableSources.
|
Modifier and Type | Method and Description |
---|---|
ObservableSource<T> |
HasUpstreamObservableSource.source()
Returns the upstream source of this Observable.
|
Modifier and Type | Class and Description |
---|---|
class |
CompletableToObservable<T>
Wraps a Completable and exposes it as an Observable.
|
Constructor and Description |
---|
CompletableFromObservable(ObservableSource<T> observable) |
Modifier and Type | Class and Description |
---|---|
class |
MaybeFlatMapIterableObservable<T,R>
Maps a success value into an Iterable and streams it back as a Flowable.
|
class |
MaybeToObservable<T>
Wraps a MaybeSource and exposes it as an Observable, relaying signals in a backpressure-aware manner
and composes cancellation through.
|
Modifier and Type | Class and Description |
---|---|
class |
CompletableAndThenObservable<R>
After Completable completes, it relays the signals
of the ObservableSource to the downstream observer.
|
class |
MaybeFlatMapObservable<T,R>
Maps the success value of a Maybe onto an ObservableSource and
relays its signals to the downstream observer.
|
class |
ObservableConcatMapMaybe<T,R>
Maps each upstream item into a
MaybeSource , subscribes to them one after the other terminates
and relays their success values, optionally delaying any errors till the main and inner sources
terminate. |
class |
ObservableConcatMapSingle<T,R>
Maps each upstream item into a
SingleSource , subscribes to them one after the other terminates
and relays their success values, optionally delaying any errors till the main and inner sources
terminate. |
class |
ObservableSwitchMapMaybe<T,R>
Maps the upstream items into
MaybeSource 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. |
class |
ObservableSwitchMapSingle<T,R>
Maps the upstream items into
SingleSource 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. |
class |
SingleFlatMapObservable<T,R>
Maps the success value of a Single onto an ObservableSource and
relays its signals to the downstream observer.
|
Constructor and Description |
---|
CompletableAndThenObservable(CompletableSource source,
ObservableSource<? extends R> other) |
Constructor and Description |
---|
MaybeFlatMapObservable(MaybeSource<T> source,
Function<? super T,? extends ObservableSource<? extends R>> mapper) |
SingleFlatMapObservable(SingleSource<T> source,
Function<? super T,? extends ObservableSource<? extends R>> mapper) |
Modifier and Type | Class and Description |
---|---|
class |
ObservableAll<T> |
class |
ObservableAmb<T> |
class |
ObservableAny<T> |
class |
ObservableAutoConnect<T>
Wraps a ConnectableObservable and calls its connect() method once
the specified number of Observers have subscribed.
|
class |
ObservableBuffer<T,U extends Collection<? super T>> |
class |
ObservableBufferBoundary<T,U extends Collection<? super T>,Open,Close> |
class |
ObservableBufferBoundarySupplier<T,U extends Collection<? super T>,B> |
class |
ObservableBufferExactBoundary<T,U extends Collection<? super T>,B> |
class |
ObservableBufferTimed<T,U extends Collection<? super T>> |
class |
ObservableCache<T>
An observable which auto-connects to another observable, caches the elements
from that observable but allows terminating the connection and completing the cache.
|
class |
ObservableCollect<T,U> |
class |
ObservableCombineLatest<T,R> |
class |
ObservableConcatMap<T,U> |
class |
ObservableConcatMapEager<T,R> |
class |
ObservableConcatWithCompletable<T>
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.
|
class |
ObservableConcatWithMaybe<T>
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.
|
class |
ObservableConcatWithSingle<T>
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.
|
class |
ObservableCount<T> |
class |
ObservableCreate<T> |
class |
ObservableDebounce<T,U> |
class |
ObservableDebounceTimed<T> |
class |
ObservableDefer<T> |
class |
ObservableDelay<T> |
class |
ObservableDelaySubscriptionOther<T,U>
Delays the subscription to the main source until the other
observable fires an event or completes.
|
class |
ObservableDematerialize<T,R> |
class |
ObservableDetach<T>
Breaks the links between the upstream and the downstream (the Disposable and
the Observer references) when the sequence terminates or gets disposed.
|
class |
ObservableDistinct<T,K> |
class |
ObservableDistinctUntilChanged<T,K> |
class |
ObservableDoAfterNext<T>
Calls a consumer after pushing the current item to the downstream.
|
class |
ObservableDoFinally<T>
Execute an action after an onError, onComplete or a dispose event.
|
class |
ObservableDoOnEach<T> |
class |
ObservableDoOnLifecycle<T> |
class |
ObservableElementAt<T> |
class |
ObservableEmpty |
class |
ObservableError<T> |
class |
ObservableFilter<T> |
class |
ObservableFlatMap<T,U> |
class |
ObservableFlatMapCompletable<T>
Maps a sequence of values into CompletableSources and awaits their termination.
|
class |
ObservableFlatMapMaybe<T,R>
Maps upstream values into MaybeSources and merges their signals into one sequence.
|
class |
ObservableFlatMapSingle<T,R>
Maps upstream values into SingleSources and merges their signals into one sequence.
|
class |
ObservableFlattenIterable<T,R>
Maps a sequence into an Iterable and emits its values.
|
class |
ObservableFromArray<T> |
class |
ObservableFromCallable<T>
Calls a Callable and emits its resulting single value or signals its exception.
|
class |
ObservableFromFuture<T> |
class |
ObservableFromIterable<T> |
class |
ObservableFromPublisher<T> |
class |
ObservableFromUnsafeSource<T> |
class |
ObservableGenerate<T,S> |
class |
ObservableGroupBy<T,K,V> |
class |
ObservableGroupJoin<TLeft,TRight,TLeftEnd,TRightEnd,R> |
class |
ObservableHide<T>
Hides the identity of the wrapped ObservableSource and its Disposable.
|
class |
ObservableIgnoreElements<T> |
class |
ObservableInterval |
class |
ObservableIntervalRange |
class |
ObservableJoin<TLeft,TRight,TLeftEnd,TRightEnd,R> |
class |
ObservableJust<T>
Represents a constant scalar value.
|
class |
ObservableLift<R,T>
Allows lifting operators into a chain of Observables.
|
class |
ObservableMap<T,U> |
class |
ObservableMapNotification<T,R> |
class |
ObservableMaterialize<T> |
class |
ObservableMergeWithCompletable<T>
Merges an Observable and a Completable by emitting the items of the Observable and waiting until
both the Observable and Completable complete normally.
|
class |
ObservableMergeWithMaybe<T>
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.
|
class |
ObservableMergeWithSingle<T>
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.
|
class |
ObservableNever |
class |
ObservableObserveOn<T> |
class |
ObservableOnErrorNext<T> |
class |
ObservableOnErrorReturn<T> |
class |
ObservablePublish<T>
A connectable observable which shares an underlying source and dispatches source values to observers in a backpressure-aware
manner.
|
class |
ObservablePublishSelector<T,R>
Shares a source Observable for the duration of a selector function.
|
class |
ObservableRange
Emits a range of integer values from start to end.
|
class |
ObservableRangeLong |
class |
ObservableRefCount<T>
Returns an observable sequence that stays connected to the source as long as
there is at least one subscription to the observable sequence.
|
class |
ObservableRepeat<T> |
class |
ObservableRepeatUntil<T> |
class |
ObservableRepeatWhen<T>
Repeatedly subscribe to a source if a handler ObservableSource signals an item.
|
class |
ObservableReplay<T> |
class |
ObservableRetryBiPredicate<T> |
class |
ObservableRetryPredicate<T> |
class |
ObservableRetryWhen<T>
Repeatedly subscribe to a source if a handler ObservableSource signals an item.
|
class |
ObservableSampleTimed<T> |
class |
ObservableSampleWithObservable<T> |
class |
ObservableScan<T> |
class |
ObservableScanSeed<T,R> |
class |
ObservableSequenceEqual<T> |
class |
ObservableSerialized<T> |
class |
ObservableSkip<T> |
class |
ObservableSkipLast<T> |
class |
ObservableSkipLastTimed<T> |
class |
ObservableSkipUntil<T,U> |
class |
ObservableSkipWhile<T> |
class |
ObservableSubscribeOn<T> |
class |
ObservableSwitchIfEmpty<T> |
class |
ObservableSwitchMap<T,R> |
class |
ObservableTake<T> |
class |
ObservableTakeLast<T> |
class |
ObservableTakeLastOne<T> |
class |
ObservableTakeLastTimed<T> |
class |
ObservableTakeUntil<T,U> |
class |
ObservableTakeUntilPredicate<T> |
class |
ObservableTakeWhile<T> |
class |
ObservableThrottleFirstTimed<T> |
class |
ObservableThrottleLatest<T>
Emits the next or latest item when the given time elapses.
|
class |
ObservableTimeInterval<T> |
class |
ObservableTimeout<T,U,V> |
class |
ObservableTimeoutTimed<T> |
class |
ObservableTimer |
class |
ObservableToList<T,U extends Collection<? super T>> |
class |
ObservableUnsubscribeOn<T> |
class |
ObservableUsing<T,D> |
class |
ObservableWindow<T> |
class |
ObservableWindowBoundary<T,B> |
class |
ObservableWindowBoundarySelector<T,B,V> |
class |
ObservableWindowBoundarySupplier<T,B> |
class |
ObservableWindowTimed<T> |
class |
ObservableWithLatestFrom<T,U,R> |
class |
ObservableWithLatestFromMany<T,R>
Combines a main sequence of values with the latest from multiple other sequences via
a selector function.
|
class |
ObservableZip<T,R> |
class |
ObservableZipIterable<T,U,V> |
Modifier and Type | Method and Description |
---|---|
ObservableSource<T> |
ObservableReplay.source() |
ObservableSource<T> |
ObservablePublish.source() |
Modifier and Type | Method and Description |
---|---|
static <T,U> Function<T,ObservableSource<U>> |
ObservableInternalHelper.flatMapIntoIterable(Function<? super T,? extends Iterable<? extends U>> mapper) |
static <T,U,R> Function<T,ObservableSource<R>> |
ObservableInternalHelper.flatMapWithCombiner(Function<? super T,? extends ObservableSource<? extends U>> mapper,
BiFunction<? super T,? super U,? extends R> combiner) |
static <T,U> Function<T,ObservableSource<T>> |
ObservableInternalHelper.itemDelay(Function<? super T,? extends ObservableSource<U>> itemDelay) |
static <T,R> Function<Observable<T>,ObservableSource<R>> |
ObservableInternalHelper.replayFunction(Function<? super Observable<T>,? extends ObservableSource<R>> selector,
Scheduler scheduler) |
static <T,R> Function<List<ObservableSource<? extends T>>,ObservableSource<? extends R>> |
ObservableInternalHelper.zipIterable(Function<? super Object[],? extends R> zipper) |
static <T,R> Function<List<ObservableSource<? extends T>>,ObservableSource<? extends R>> |
ObservableInternalHelper.zipIterable(Function<? super Object[],? extends R> zipper) |
Modifier and Type | Method and Description |
---|---|
static <T> ConnectableObservable<T> |
ObservablePublish.create(ObservableSource<T> source)
Creates a OperatorPublish instance to publish values of the given source observable.
|
static <T> ConnectableObservable<T> |
ObservableReplay.create(ObservableSource<T> source,
int bufferSize)
Creates a replaying ConnectableObservable with a size bound buffer.
|
static <T> ConnectableObservable<T> |
ObservableReplay.create(ObservableSource<T> source,
long maxAge,
TimeUnit unit,
Scheduler scheduler)
Creates a replaying ConnectableObservable with a time bound buffer.
|
static <T> ConnectableObservable<T> |
ObservableReplay.create(ObservableSource<T> source,
long maxAge,
TimeUnit unit,
Scheduler scheduler,
int bufferSize)
Creates a replaying ConnectableObservable with a size and time bound buffer.
|
static <T> ConnectableObservable<T> |
ObservableReplay.createFrom(ObservableSource<? extends T> source)
Creates a replaying ConnectableObservable with an unbounded buffer.
|
static <T> void |
ObservableBlockingSubscribe.subscribe(ObservableSource<? extends T> o)
Runs the source observable to a terminal event, ignoring any values and rethrowing any exception.
|
static <T> void |
ObservableBlockingSubscribe.subscribe(ObservableSource<? extends T> o,
Consumer<? super T> onNext,
Consumer<? super Throwable> onError,
Action onComplete)
Subscribes to the source and calls the given actions on the current thread.
|
static <T> void |
ObservableBlockingSubscribe.subscribe(ObservableSource<? extends T> o,
Observer<? super T> observer)
Subscribes to the source and calls the Observer methods on the current thread.
|
static <T,R> boolean |
ObservableScalarXMap.tryScalarXMapSubscribe(ObservableSource<T> source,
Observer<? super R> observer,
Function<? super T,? extends ObservableSource<? extends R>> mapper)
Tries to subscribe to a possibly Callable source's mapped ObservableSource.
|
Modifier and Type | Method and Description |
---|---|
static <T,U,R> Function<T,ObservableSource<R>> |
ObservableInternalHelper.flatMapWithCombiner(Function<? super T,? extends ObservableSource<? extends U>> mapper,
BiFunction<? super T,? super U,? extends R> combiner) |
static <T,U> Function<T,ObservableSource<T>> |
ObservableInternalHelper.itemDelay(Function<? super T,? extends ObservableSource<U>> itemDelay) |
static <U,R> Observable<R> |
ObservableReplay.multicastSelector(Callable<? 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,R> Function<Observable<T>,ObservableSource<R>> |
ObservableInternalHelper.replayFunction(Function<? super Observable<T>,? extends ObservableSource<R>> selector,
Scheduler scheduler) |
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.
|
void |
ObservableMapNotification.subscribeActual(Observer<? super ObservableSource<? extends R>> t) |
static <T,R> boolean |
ObservableScalarXMap.tryScalarXMapSubscribe(ObservableSource<T> source,
Observer<? super R> observer,
Function<? super T,? extends ObservableSource<? extends R>> mapper)
Tries to subscribe to a possibly Callable source's mapped ObservableSource.
|
Constructor and Description |
---|
ObservableAmb(ObservableSource<? extends T>[] sources,
Iterable<? extends ObservableSource<? extends T>> sourcesIterable) |
ObservableBufferBoundary(ObservableSource<T> source,
ObservableSource<? extends Open> bufferOpen,
Function<? super Open,? extends ObservableSource<? extends Close>> bufferClose,
Callable<U> bufferSupplier) |
ObservableBufferBoundarySupplier(ObservableSource<T> source,
Callable<? extends ObservableSource<B>> boundarySupplier,
Callable<U> bufferSupplier) |
ObservableCombineLatest(ObservableSource<? extends T>[] sources,
Iterable<? extends ObservableSource<? extends T>> sourcesIterable,
Function<? super Object[],? extends R> combiner,
int bufferSize,
boolean delayError) |
ObservableConcatMap(ObservableSource<T> source,
Function<? super T,? extends ObservableSource<? extends U>> mapper,
int bufferSize,
ErrorMode delayErrors) |
ObservableConcatMapEager(ObservableSource<T> source,
Function<? super T,? extends ObservableSource<? extends R>> mapper,
ErrorMode errorMode,
int maxConcurrency,
int prefetch) |
ObservableDebounce(ObservableSource<T> source,
Function<? super T,? extends ObservableSource<U>> debounceSelector) |
ObservableDefer(Callable<? extends ObservableSource<? extends T>> supplier) |
ObservableFlatMap(ObservableSource<T> source,
Function<? super T,? extends ObservableSource<? extends U>> mapper,
boolean delayErrors,
int maxConcurrency,
int bufferSize) |
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) |
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) |
ObservableJoin(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 TRight,? extends R> resultSelector) |
ObservableJoin(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 TRight,? extends R> resultSelector) |
ObservableMapNotification(ObservableSource<T> source,
Function<? super T,? extends ObservableSource<? extends R>> onNextMapper,
Function<? super Throwable,? extends ObservableSource<? extends R>> onErrorMapper,
Callable<? extends ObservableSource<? extends R>> onCompleteSupplier) |
ObservableMapNotification(ObservableSource<T> source,
Function<? super T,? extends ObservableSource<? extends R>> onNextMapper,
Function<? super Throwable,? extends ObservableSource<? extends R>> onErrorMapper,
Callable<? extends ObservableSource<? extends R>> onCompleteSupplier) |
ObservableMapNotification(ObservableSource<T> source,
Function<? super T,? extends ObservableSource<? extends R>> onNextMapper,
Function<? super Throwable,? extends ObservableSource<? extends R>> onErrorMapper,
Callable<? extends ObservableSource<? extends R>> onCompleteSupplier) |
ObservableOnErrorNext(ObservableSource<T> source,
Function<? super Throwable,? extends ObservableSource<? extends T>> nextSupplier,
boolean allowFatal) |
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) |
ObservableSwitchMap(ObservableSource<T> source,
Function<? super T,? extends ObservableSource<? extends R>> mapper,
int bufferSize,
boolean delayErrors) |
ObservableTimeout(Observable<T> source,
ObservableSource<U> firstTimeoutIndicator,
Function<? super T,? extends ObservableSource<V>> itemTimeoutIndicator,
ObservableSource<? extends T> other) |
ObservableUsing(Callable<? extends D> resourceSupplier,
Function<? super D,? extends ObservableSource<? extends T>> sourceSupplier,
Consumer<? super D> disposer,
boolean eager) |
ObservableWindowBoundarySelector(ObservableSource<T> source,
ObservableSource<B> open,
Function<? super B,? extends ObservableSource<V>> close,
int bufferSize) |
ObservableWindowBoundarySupplier(ObservableSource<T> source,
Callable<? extends ObservableSource<B>> other,
int capacityHint) |
ObservableWithLatestFromMany(ObservableSource<T> source,
Iterable<? extends ObservableSource<?>> otherIterable,
Function<? super Object[],R> combiner) |
ObservableZip(ObservableSource<? extends T>[] sources,
Iterable<? extends ObservableSource<? extends T>> sourcesIterable,
Function<? super Object[],? extends R> zipper,
int bufferSize,
boolean delayError) |
Modifier and Type | Class and Description |
---|---|
class |
SingleFlatMapIterableObservable<T,R>
Maps a success value into an Iterable and streams it back as an Observable.
|
class |
SingleToObservable<T>
Wraps a Single and exposes it as an Observable.
|
Constructor and Description |
---|
SingleDelayWithObservable(SingleSource<T> source,
ObservableSource<U> other) |
Modifier and Type | Class and Description |
---|---|
class |
ConnectableObservable<T>
A
ConnectableObservable resembles an ordinary Observable , except that it does not begin
emitting items when it is subscribed to, but only when its ConnectableObservable.connect(io.reactivex.functions.Consumer<? super io.reactivex.disposables.Disposable>) method is called. |
class |
GroupedObservable<K,T>
An
Observable that has been grouped by key, the value of which can be obtained with GroupedObservable.getKey() . |
Modifier and Type | Class and Description |
---|---|
class |
AsyncSubject<T>
A Subject that emits the very last value followed by a completion event or the received error to Observers.
|
class |
BehaviorSubject<T>
Subject that emits the most recent item it has observed and all subsequent observed items to each subscribed
Observer . |
class |
PublishSubject<T>
A Subject that emits (multicasts) items to currently subscribed
Observer s and terminal events to current
or late Observer s. |
class |
ReplaySubject<T>
Replays events (in a configurable bounded or unbounded manner) to current and late
Observer s. |
class |
Subject<T>
Represents an
Observer and an Observable at the same time, allowing
multicasting events from a single source to multiple child Observer s. |
class |
UnicastSubject<T>
A Subject that queues up events until a single
Observer subscribes to it, replays
those events to it until the Observer catches up and then switches to relaying events live to
this single Observer until this UnicastSubject terminates or the Observer unsubscribes. |
Copyright © 2019. All rights reserved.