Package | Description |
---|---|
rx |
Rx Observables
|
rx.observables | |
rx.plugins | |
rx.subjects |
Modifier and Type | Method and Description |
---|---|
Observable<Boolean> |
Observable.all(Func1<? super T,Boolean> predicate)
Returns an Observable that emits a Boolean that indicates whether all of the items emitted by the source
Observable satisfy a condition.
|
static <T> Observable<T> |
Observable.amb(Iterable<? extends Observable<? extends T>> sources)
Mirrors the one Observable in an Iterable of several Observables that first either emits an item or sends
a termination notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2)
Given two Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3)
Given three Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4)
Given four Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5)
Given five Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6)
Given six Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6,
Observable<? extends T> o7)
Given seven Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6,
Observable<? extends T> o7,
Observable<? extends T> o8)
Given eight Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6,
Observable<? extends T> o7,
Observable<? extends T> o8,
Observable<? extends T> o9)
Given nine Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
Observable<T> |
Observable.ambWith(Observable<? extends T> t1)
Mirrors the Observable (current or provided) that first either emits an item or sends a termination
notification.
|
Observable<T> |
Observable.asObservable()
Portrays a object of an Observable subclass as a simple Observable object.
|
<TClosing> Observable<List<T>> |
Observable.buffer(Func0<? extends Observable<? extends TClosing>> bufferClosingSelector)
Returns an Observable that emits buffers of items it collects from the source Observable.
|
Observable<List<T>> |
Observable.buffer(int count)
Returns an Observable that emits buffers of items it collects from the source Observable.
|
Observable<List<T>> |
Observable.buffer(int count,
int skip)
Returns an Observable that emits buffers of items it collects from the source Observable.
|
Observable<List<T>> |
Observable.buffer(long timespan,
long timeshift,
TimeUnit unit)
Returns an Observable that emits buffers of items it collects from the source Observable.
|
Observable<List<T>> |
Observable.buffer(long timespan,
long timeshift,
TimeUnit unit,
Scheduler scheduler)
Returns an Observable that emits buffers of items it collects from the source Observable.
|
Observable<List<T>> |
Observable.buffer(long timespan,
TimeUnit unit)
Returns an Observable that emits buffers of items it collects from the source Observable.
|
Observable<List<T>> |
Observable.buffer(long timespan,
TimeUnit unit,
int count)
Returns an Observable that emits buffers of items it collects from the source Observable.
|
Observable<List<T>> |
Observable.buffer(long timespan,
TimeUnit unit,
int count,
Scheduler scheduler)
Returns an Observable that emits buffers of items it collects from the source Observable.
|
Observable<List<T>> |
Observable.buffer(long timespan,
TimeUnit unit,
Scheduler scheduler)
Returns an Observable that emits buffers of items it collects from the source Observable.
|
<TOpening,TClosing> |
Observable.buffer(Observable<? extends TOpening> bufferOpenings,
Func1<? super TOpening,? extends Observable<? extends TClosing>> bufferClosingSelector)
Returns an Observable that emits buffers of items it collects from the source Observable.
|
<B> Observable<List<T>> |
Observable.buffer(Observable<B> boundary)
Returns an Observable that emits non-overlapping buffered items from the source Observable each time the
specified boundary Observable emits an item.
|
<B> Observable<List<T>> |
Observable.buffer(Observable<B> boundary,
int initialCapacity)
Returns an Observable that emits non-overlapping buffered items from the source Observable each time the
specified boundary Observable emits an item.
|
Observable<T> |
Observable.cache()
Caches the emissions from the source Observable and replays them in order to any subsequent Subscribers.
|
Observable<T> |
Observable.cache(int capacityHint)
Caches emissions from the source Observable and replays them in order to any subsequent Subscribers.
|
<R> Observable<R> |
Observable.cast(Class<R> klass)
Returns an Observable that emits the items emitted by the source Observable, converted to the specified
type.
|
<R> Observable<R> |
Observable.collect(Func0<R> stateFactory,
Action2<R,? super T> collector)
Collects items emitted by the source Observable into a single mutable data structure and returns an
Observable that emits this structure.
|
static <T,R> Observable<R> |
Observable.combineLatest(List<? extends Observable<? extends T>> sources,
FuncN<? extends R> combineFunction)
Combines a list of source Observables by emitting an item that aggregates the latest values of each of
the source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,R> Observable<R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Func2<? super T1,? super T2,? extends R> combineFunction)
Combines two source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from either of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Func3<? super T1,? super T2,? super T3,? extends R> combineFunction)
Combines three source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Func4<? super T1,? super T2,? super T3,? super T4,? extends R> combineFunction)
Combines four source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Func5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> combineFunction)
Combines five source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Func6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> combineFunction)
Combines six source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Func7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> combineFunction)
Combines seven source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Func8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> combineFunction)
Combines eight source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Observable<? extends T9> o9,
Func9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> combineFunction)
Combines nine source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
<R> Observable<R> |
Observable.compose(Observable.Transformer<? super T,? extends R> transformer)
Transform an Observable by applying a particular Transformer function to it.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends Observable<? extends T>> observables)
Returns an Observable that emits the items emitted by each of the Observables emitted by the source
Observable, one after the other, without interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2)
Returns an Observable that emits the items emitted by two Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3)
Returns an Observable that emits the items emitted by three Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4)
Returns an Observable that emits the items emitted by four Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5)
Returns an Observable that emits the items emitted by five Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6)
Returns an Observable that emits the items emitted by six Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7)
Returns an Observable that emits the items emitted by seven Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8)
Returns an Observable that emits the items emitted by eight Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Returns an Observable that emits the items emitted by nine Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Single.concat(Single<? extends T> t1,
Single<? extends T> t2)
Returns an Observable that emits the items emitted by two Singles, one after the other.
|
static <T> Observable<T> |
Single.concat(Single<? extends T> t1,
Single<? extends T> t2,
Single<? extends T> t3)
Returns an Observable that emits the items emitted by three Singles, one after the other.
|
static <T> Observable<T> |
Single.concat(Single<? extends T> t1,
Single<? extends T> t2,
Single<? extends T> t3,
Single<? extends T> t4)
Returns an Observable that emits the items emitted by four Singles, one after the other.
|
static <T> Observable<T> |
Single.concat(Single<? extends T> t1,
Single<? extends T> t2,
Single<? extends T> t3,
Single<? extends T> t4,
Single<? extends T> t5)
Returns an Observable that emits the items emitted by five Singles, one after the other.
|
static <T> Observable<T> |
Single.concat(Single<? extends T> t1,
Single<? extends T> t2,
Single<? extends T> t3,
Single<? extends T> t4,
Single<? extends T> t5,
Single<? extends T> t6)
Returns an Observable that emits the items emitted by six Singles, one after the other.
|
static <T> Observable<T> |
Single.concat(Single<? extends T> t1,
Single<? extends T> t2,
Single<? extends T> t3,
Single<? extends T> t4,
Single<? extends T> t5,
Single<? extends T> t6,
Single<? extends T> t7)
Returns an Observable that emits the items emitted by seven Singles, one after the other.
|
static <T> Observable<T> |
Single.concat(Single<? extends T> t1,
Single<? extends T> t2,
Single<? extends T> t3,
Single<? extends T> t4,
Single<? extends T> t5,
Single<? extends T> t6,
Single<? extends T> t7,
Single<? extends T> t8)
Returns an Observable that emits the items emitted by eight Singles, one after the other.
|
static <T> Observable<T> |
Single.concat(Single<? extends T> t1,
Single<? extends T> t2,
Single<? extends T> t3,
Single<? extends T> t4,
Single<? extends T> t5,
Single<? extends T> t6,
Single<? extends T> t7,
Single<? extends T> t8,
Single<? extends T> t9)
Returns an Observable that emits the items emitted by nine Singles, one after the other.
|
<R> Observable<R> |
Observable.concatMap(Func1<? super T,? extends Observable<? extends R>> func)
Returns a new Observable that emits items resulting from applying a function that you supply to each item
emitted by the source Observable, where that function returns an Observable, and then emitting the items
that result from concatinating those resulting Observables.
|
Observable<T> |
Observable.concatWith(Observable<? extends T> t1)
Returns an Observable that emits the items emitted from the current Observable, then the next, one after
the other, without interleaving them.
|
Observable<T> |
Single.concatWith(Single<? extends T> t1)
Returns an Observable that emits the item emitted by the source Single, then the item emitted by the
specified Single.
|
Observable<Boolean> |
Observable.contains(Object element)
Returns an Observable that emits a Boolean that indicates whether the source Observable emitted a
specified item.
|
Observable<Integer> |
Observable.count()
Returns an Observable that emits the count of the total number of items emitted by the source Observable.
|
Observable<Long> |
Observable.countLong()
Returns an Observable that counts the total number of items emitted by the source Observable and emits
this count as a 64-bit Long.
|
static <T> Observable<T> |
Observable.create(Observable.OnSubscribe<T> f)
Returns an Observable that will execute the specified function when a
Subscriber subscribes to
it. |
<U> Observable<T> |
Observable.debounce(Func1<? super T,? extends Observable<U>> debounceSelector)
Returns an Observable that mirrors the source Observable, except that it drops items emitted by the
source Observable that are followed by another item within a computed debounce duration.
|
Observable<T> |
Observable.debounce(long timeout,
TimeUnit unit)
Returns an Observable that mirrors the source Observable, except that it drops items emitted by the
source Observable that are followed by newer items before a timeout value expires.
|
Observable<T> |
Observable.debounce(long timeout,
TimeUnit unit,
Scheduler scheduler)
Returns an Observable that mirrors the source Observable, except that it drops items emitted by the
source Observable that are followed by newer items before a timeout value expires on a specified
Scheduler.
|
Observable<T> |
Observable.defaultIfEmpty(T defaultValue)
Returns an Observable that emits the items emitted by the source Observable or a specified default item
if the source Observable is empty.
|
static <T> Observable<T> |
Observable.defer(Func0<Observable<T>> observableFactory)
Returns an Observable that calls an Observable factory to create an Observable for each new Observer
that subscribes.
|
<U,V> Observable<T> |
Observable.delay(Func0<? extends Observable<U>> subscriptionDelay,
Func1<? super T,? extends Observable<V>> itemDelay)
Returns an Observable that delays the subscription to and emissions from the souce Observable via another
Observable on a per-item basis.
|
<U> Observable<T> |
Observable.delay(Func1<? super T,? extends Observable<U>> itemDelay)
Returns an Observable that delays the emissions of the source Observable via another Observable on a
per-item basis.
|
Observable<T> |
Observable.delay(long delay,
TimeUnit unit)
Returns an Observable that emits the items emitted by the source Observable shifted forward in time by a
specified delay.
|
Observable<T> |
Observable.delay(long delay,
TimeUnit unit,
Scheduler scheduler)
Returns an Observable that emits the items emitted by the source Observable shifted forward in time by a
specified delay.
|
<U> Observable<T> |
Observable.delaySubscription(Func0<? extends Observable<U>> subscriptionDelay)
Returns an Observable that delays the subscription to the source Observable until a second Observable
emits an item.
|
Observable<T> |
Observable.delaySubscription(long delay,
TimeUnit unit)
Returns an Observable that delays the subscription to the source Observable by a given amount of time.
|
Observable<T> |
Observable.delaySubscription(long delay,
TimeUnit unit,
Scheduler scheduler)
Returns an Observable that delays the subscription to the source Observable by a given amount of time,
both waiting and subscribing on a given Scheduler.
|
<T2> Observable<T2> |
Observable.dematerialize()
Returns an Observable that reverses the effect of
materialize by transforming the
Notification objects emitted by the source Observable into the items or notifications they
represent. |
Observable<T> |
Observable.distinct()
Returns an Observable that emits all items emitted by the source Observable that are distinct.
|
<U> Observable<T> |
Observable.distinct(Func1<? super T,? extends U> keySelector)
Returns an Observable that emits all items emitted by the source Observable that are distinct according
to a key selector function.
|
Observable<T> |
Observable.distinctUntilChanged()
Returns an Observable that emits all items emitted by the source Observable that are distinct from their
immediate predecessors.
|
<U> Observable<T> |
Observable.distinctUntilChanged(Func1<? super T,? extends U> keySelector)
Returns an Observable that emits all items emitted by the source Observable that are distinct from their
immediate predecessors, according to a key selector function.
|
Observable<T> |
Observable.doOnCompleted(Action0 onCompleted)
Modifies the source Observable so that it invokes an action when it calls
onCompleted . |
Observable<T> |
Observable.doOnEach(Action1<Notification<? super T>> onNotification)
Modifies the source Observable so that it invokes an action for each item it emits.
|
Observable<T> |
Observable.doOnEach(Observer<? super T> observer)
Modifies the source Observable so that it notifies an Observer for each item it emits.
|
Observable<T> |
Observable.doOnError(Action1<Throwable> onError)
Modifies the source Observable so that it invokes an action if it calls
onError . |
Observable<T> |
Observable.doOnNext(Action1<? super T> onNext)
Modifies the source Observable so that it invokes an action when it calls
onNext . |
Observable<T> |
Observable.doOnRequest(Action1<Long> onRequest)
Modifies the source
Observable so that it invokes the given action when it receives a request for
more items. |
Observable<T> |
Observable.doOnSubscribe(Action0 subscribe)
Modifies the source
Observable so that it invokes the given action when it is subscribed from
its subscribers. |
Observable<T> |
Observable.doOnTerminate(Action0 onTerminate)
Modifies the source Observable so that it invokes an action when it calls
onCompleted or
onError . |
Observable<T> |
Observable.doOnUnsubscribe(Action0 unsubscribe)
Modifies the source
Observable so that it invokes the given action when it is unsubscribed from
its subscribers. |
Observable<T> |
Observable.elementAt(int index)
Returns an Observable that emits the single item at a specified index in a sequence of emissions from a
source Observbable.
|
Observable<T> |
Observable.elementAtOrDefault(int index,
T defaultValue)
Returns an Observable that emits the item found at a specified index in a sequence of emissions from a
source Observable, or a default item if that index is out of range.
|
static <T> Observable<T> |
Observable.empty()
Returns an Observable that emits no items to the
Observer and immediately invokes its
onCompleted method. |
static <T> Observable<T> |
Observable.error(Throwable exception)
|
Observable<Boolean> |
Observable.exists(Func1<? super T,Boolean> predicate)
Returns an Observable that emits
true if any item emitted by the source Observable satisfies a
specified condition, otherwise false . |
Observable<T> |
Observable.filter(Func1<? super T,Boolean> predicate)
Filters items emitted by an Observable by only emitting those that satisfy a specified predicate.
|
Observable<T> |
Observable.finallyDo(Action0 action)
|
Observable<T> |
Observable.first()
Returns an Observable that emits only the very first item emitted by the source Observable, or notifies
of an
NoSuchElementException if the source Observable is empty. |
Observable<T> |
Observable.first(Func1<? super T,Boolean> predicate)
Returns an Observable that emits only the very first item emitted by the source Observable that satisfies
a specified condition, or notifies of an
NoSuchElementException if no such items are emitted. |
Observable<T> |
Observable.firstOrDefault(T defaultValue)
Returns an Observable that emits only the very first item emitted by the source Observable, or a default
item if the source Observable completes without emitting anything.
|
Observable<T> |
Observable.firstOrDefault(T defaultValue,
Func1<? super T,Boolean> predicate)
Returns an Observable that emits only the very first item emitted by the source Observable that satisfies
a specified condition, or a default item if the source Observable emits no such items.
|
<R> Observable<R> |
Observable.flatMap(Func1<? super T,? extends Observable<? extends R>> func)
Returns an Observable that emits items based on applying a function that you supply to each item emitted
by the source Observable, where that function returns an Observable, and then merging those resulting
Observables and emitting the results of this merger.
|
<R> Observable<R> |
Observable.flatMap(Func1<? super T,? extends Observable<? extends R>> onNext,
Func1<? super Throwable,? extends Observable<? extends R>> onError,
Func0<? extends Observable<? extends R>> onCompleted)
Returns an Observable that applies a function to each item emitted or notification raised by the source
Observable and then flattens the Observables returned from these functions and emits the resulting items.
|
<R> Observable<R> |
Observable.flatMap(Func1<? super T,? extends Observable<? extends R>> onNext,
Func1<? super Throwable,? extends Observable<? extends R>> onError,
Func0<? extends Observable<? extends R>> onCompleted,
int maxConcurrent)
Returns an Observable that applies a function to each item emitted or notification raised by the source
Observable and then flattens the Observables returned from these functions and emits the resulting items,
while limiting the maximum number of concurrent subscriptions to these Observables.
|
<R> Observable<R> |
Observable.flatMap(Func1<? super T,? extends Observable<? extends R>> func,
int maxConcurrent)
Returns an Observable that emits items based on applying a function that you supply to each item emitted
by the source Observable, where that function returns an Observable, and then merging those resulting
Observables and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these Observables.
|
<U,R> Observable<R> |
Observable.flatMap(Func1<? super T,? extends Observable<? extends U>> collectionSelector,
Func2<? 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 Observable and a specified collection Observable.
|
<U,R> Observable<R> |
Observable.flatMap(Func1<? super T,? extends Observable<? extends U>> collectionSelector,
Func2<? super T,? super U,? extends R> resultSelector,
int maxConcurrent)
Returns an Observable that emits the results of a specified function to the pair of values emitted by the
source Observable and a specified collection Observable, while limiting the maximum number of concurrent
subscriptions to these Observables.
|
<R> Observable<R> |
Observable.flatMapIterable(Func1<? super T,? extends Iterable<? extends R>> collectionSelector)
Returns an Observable that merges each item emitted by the source Observable with the values in an
Iterable corresponding to that item that is generated by a selector.
|
<U,R> Observable<R> |
Observable.flatMapIterable(Func1<? super T,? extends Iterable<? extends U>> collectionSelector,
Func2<? super T,? super U,? extends R> resultSelector)
Returns an Observable that emits the results of applying a function to the pair of values from the source
Observable and an Iterable corresponding to that item that is generated by a selector.
|
<R> Observable<R> |
Single.flatMapObservable(Func1<? super T,? extends Observable<? extends R>> func)
Returns an Observable that emits items based on applying a specified function to the item emitted by the
source Observable, where that function returns an Observable.
|
static <T> Observable<T> |
Observable.from(Future<? extends T> future)
Converts a
Future into an Observable. |
static <T> Observable<T> |
Observable.from(Future<? extends T> future,
long timeout,
TimeUnit unit)
Converts a
Future into an Observable, with a timeout on the Future. |
static <T> Observable<T> |
Observable.from(Future<? extends T> future,
Scheduler scheduler)
|
static <T> Observable<T> |
Observable.from(Iterable<? extends T> iterable)
Converts an
Iterable sequence into an Observable that emits the items in the sequence. |
static <T> Observable<T> |
Observable.from(T[] array)
Converts an Array into an Observable that emits the items in the Array.
|
<K> Observable<GroupedObservable<K,T>> |
Observable.groupBy(Func1<? super T,? extends K> keySelector)
Groups the items emitted by an
Observable according to a specified criterion, and emits these
grouped items as GroupedObservable s, one GroupedObservable per group. |
<K,R> Observable<GroupedObservable<K,R>> |
Observable.groupBy(Func1<? super T,? extends K> keySelector,
Func1<? super T,? extends R> elementSelector)
Groups the items emitted by an
Observable according to a specified criterion, and emits these
grouped items as GroupedObservable s, one GroupedObservable per group. |
<T2,D1,D2,R> |
Observable.groupJoin(Observable<T2> right,
Func1<? super T,? extends Observable<D1>> leftDuration,
Func1<? super T2,? extends Observable<D2>> rightDuration,
Func2<? super T,? super Observable<T2>,? extends R> resultSelector)
Returns an Observable that correlates two Observables when they overlap in time and groups the results.
|
Observable<T> |
Observable.ignoreElements()
Ignores all items emitted by the source Observable and only calls
onCompleted or onError . |
static Observable<Long> |
Observable.interval(long initialDelay,
long period,
TimeUnit unit)
Returns an Observable that emits a
0L after the initialDelay and ever increasing numbers
after each period of time thereafter. |
static Observable<Long> |
Observable.interval(long initialDelay,
long period,
TimeUnit unit,
Scheduler scheduler)
Returns an Observable that emits a
0L after the initialDelay and ever increasing numbers
after each period of time thereafter, on a specified Scheduler . |
static Observable<Long> |
Observable.interval(long interval,
TimeUnit unit)
Returns an Observable that emits a sequential number every specified interval of time.
|
static Observable<Long> |
Observable.interval(long interval,
TimeUnit unit,
Scheduler scheduler)
Returns an Observable that emits a sequential number every specified interval of time, on a
specified Scheduler.
|
Observable<Boolean> |
Observable.isEmpty()
Returns an Observable that emits
true if the source Observable is empty, otherwise false . |
<TRight,TLeftDuration,TRightDuration,R> |
Observable.join(Observable<TRight> right,
Func1<T,Observable<TLeftDuration>> leftDurationSelector,
Func1<TRight,Observable<TRightDuration>> rightDurationSelector,
Func2<T,TRight,R> resultSelector)
Correlates the items emitted by two Observables based on overlapping durations.
|
static <T> Observable<T> |
Observable.just(T value)
Returns an Observable that emits a single item and then completes.
|
static <T> Observable<T> |
Observable.just(T t1,
T t2)
Converts two items into an Observable that emits those items.
|
static <T> Observable<T> |
Observable.just(T t1,
T t2,
T t3)
Converts three items into an Observable that emits those items.
|
static <T> Observable<T> |
Observable.just(T t1,
T t2,
T t3,
T t4)
Converts four items into an Observable that emits those items.
|
static <T> Observable<T> |
Observable.just(T t1,
T t2,
T t3,
T t4,
T t5)
Converts five items into an Observable that emits those items.
|
static <T> Observable<T> |
Observable.just(T t1,
T t2,
T t3,
T t4,
T t5,
T t6)
Converts six items into an Observable that emits those items.
|
static <T> Observable<T> |
Observable.just(T t1,
T t2,
T t3,
T t4,
T t5,
T t6,
T t7)
Converts seven items into an Observable that emits those items.
|
static <T> Observable<T> |
Observable.just(T t1,
T t2,
T t3,
T t4,
T t5,
T t6,
T t7,
T t8)
Converts eight items into an Observable that emits those items.
|
static <T> Observable<T> |
Observable.just(T t1,
T t2,
T t3,
T t4,
T t5,
T t6,
T t7,
T t8,
T t9)
Converts nine items into an Observable that emits those items.
|
static <T> Observable<T> |
Observable.just(T t1,
T t2,
T t3,
T t4,
T t5,
T t6,
T t7,
T t8,
T t9,
T t10)
Converts ten items into an Observable that emits those items.
|
Observable<T> |
Observable.last()
Returns an Observable that emits the last item emitted by the source Observable or notifies observers of
a
NoSuchElementException if the source Observable is empty. |
Observable<T> |
Observable.last(Func1<? super T,Boolean> predicate)
Returns an Observable that emits only the last item emitted by the source Observable that satisfies a
given condition, or notifies of a
NoSuchElementException if no such items are emitted. |
Observable<T> |
Observable.lastOrDefault(T defaultValue)
Returns an Observable that emits only the last item emitted by the source Observable, or a default item
if the source Observable completes without emitting any items.
|
Observable<T> |
Observable.lastOrDefault(T defaultValue,
Func1<? super T,Boolean> predicate)
Returns an Observable that emits only the last item emitted by the source Observable that satisfies a
specified condition, or a default item if no such item is emitted by the source Observable.
|
<R> Observable<R> |
Observable.lift(Observable.Operator<? extends R,? super T> lift)
Lifts a function to the current Observable and returns a new Observable that when subscribed to will pass
the values of the current Observable through the Operator function.
|
Observable<T> |
Observable.limit(int count)
Returns an Observable that emits only the first
count items emitted by the source Observable. |
<R> Observable<R> |
Observable.map(Func1<? super T,? extends R> func)
Returns an Observable that applies a specified function to each item emitted by the source Observable and
emits the results of these function applications.
|
Observable<Notification<T>> |
Observable.materialize()
Returns an Observable that represents all of the emissions and notifications from the source
Observable into emissions marked with their original types within
Notification objects. |
static <T> Observable<T> |
Observable.merge(Iterable<? extends Observable<? extends T>> sequences)
Flattens an Iterable of Observables into one Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Iterable<? extends Observable<? extends T>> sequences,
int maxConcurrent)
Flattens an Iterable of Observables into one Observable, without any transformation, while limiting the
number of concurrent subscriptions to these Observables.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends Observable<? extends T>> source)
Flattens an Observable that emits Observables into a single Observable that emits the items emitted by
those Observables, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends Observable<? extends T>> source,
int maxConcurrent)
Flattens an Observable that emits Observables into a single Observable that emits the items emitted by
those Observables, without any transformation, while limiting the maximum number of concurrent
subscriptions to these Observables.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T>[] sequences)
Flattens an Array of Observables into one Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T>[] sequences,
int maxConcurrent)
Flattens an Array of Observables into one Observable, without any transformation, while limiting the
number of concurrent subscriptions to these Observables.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2)
Flattens two Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3)
Flattens three Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4)
Flattens four Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5)
Flattens five Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6)
Flattens six Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7)
Flattens seven Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8)
Flattens eight Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Flattens nine Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Single.merge(Single<? extends T> t1,
Single<? extends T> t2)
Flattens two Singles into a single Observable, without any transformation.
|
static <T> Observable<T> |
Single.merge(Single<? extends T> t1,
Single<? extends T> t2,
Single<? extends T> t3)
Flattens three Singles into a single Observable, without any transformation.
|
static <T> Observable<T> |
Single.merge(Single<? extends T> t1,
Single<? extends T> t2,
Single<? extends T> t3,
Single<? extends T> t4)
Flattens four Singles into a single Observable, without any transformation.
|
static <T> Observable<T> |
Single.merge(Single<? extends T> t1,
Single<? extends T> t2,
Single<? extends T> t3,
Single<? extends T> t4,
Single<? extends T> t5)
Flattens five Singles into a single Observable, without any transformation.
|
static <T> Observable<T> |
Single.merge(Single<? extends T> t1,
Single<? extends T> t2,
Single<? extends T> t3,
Single<? extends T> t4,
Single<? extends T> t5,
Single<? extends T> t6)
Flattens six Singles into a single Observable, without any transformation.
|
static <T> Observable<T> |
Single.merge(Single<? extends T> t1,
Single<? extends T> t2,
Single<? extends T> t3,
Single<? extends T> t4,
Single<? extends T> t5,
Single<? extends T> t6,
Single<? extends T> t7)
Flattens seven Singles into a single Observable, without any transformation.
|
static <T> Observable<T> |
Single.merge(Single<? extends T> t1,
Single<? extends T> t2,
Single<? extends T> t3,
Single<? extends T> t4,
Single<? extends T> t5,
Single<? extends T> t6,
Single<? extends T> t7,
Single<? extends T> t8)
Flattens eight Singles into a single Observable, without any transformation.
|
static <T> Observable<T> |
Single.merge(Single<? extends T> t1,
Single<? extends T> t2,
Single<? extends T> t3,
Single<? extends T> t4,
Single<? extends T> t5,
Single<? extends T> t6,
Single<? extends T> t7,
Single<? extends T> t8,
Single<? extends T> t9)
Flattens nine Singles into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends Observable<? extends T>> source)
Flattens an Observable that emits Observables into one Observable, in a way that allows an Observer to
receive all successfully emitted items from all of the source Observables without being interrupted by
an error notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends Observable<? extends T>> source,
int maxConcurrent)
Flattens an Observable that emits Observables into one Observable, in a way that allows an Observer to
receive all successfully emitted items from all of the source Observables without being interrupted by
an error notification from one of them, while limiting the
number of concurrent subscriptions to these Observables.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2)
Flattens two Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from each of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3)
Flattens three Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4)
Flattens four Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5)
Flattens five Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6)
Flattens six Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7)
Flattens seven Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8)
Flattens eight Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Flattens nine Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
Observable<T> |
Observable.mergeWith(Observable<? extends T> t1)
Flattens this and another Observable into a single Observable, without any transformation.
|
Observable<T> |
Single.mergeWith(Single<? extends T> t1)
Flattens this and another Single into a single Observable, without any transformation.
|
Observable<Observable<T>> |
Observable.nest()
Converts the source
Observable<T> into an Observable<Observable<T>> that emits the
source Observable as its single emission. |
static <T> Observable<T> |
Observable.never()
Returns an Observable that never sends any items or notifications to an
Observer . |
Observable<T> |
Observable.observeOn(Scheduler scheduler)
Modifies an Observable to perform its emissions and notifications on a specified
Scheduler ,
asynchronously with an unbounded buffer. |
<R> Observable<R> |
Observable.ofType(Class<R> klass)
Filters the items emitted by an Observable, only emitting those of the specified type.
|
Observable<T> |
Observable.onBackpressureBlock()
Deprecated.
The operator doesn't work properly with
subscribeOn(Scheduler) and is prone to
deadlocks. It will be removed/unavailable starting from 1.1. |
Observable<T> |
Observable.onBackpressureBlock(int maxQueueLength)
Deprecated.
The operator doesn't work properly with
subscribeOn(Scheduler) and is prone to
deadlocks. It will be removed/unavailable starting from 1.1. |
Observable<T> |
Observable.onBackpressureBuffer()
Instructs an Observable that is emitting items faster than its observer can consume them to buffer these
items indefinitely until they can be emitted.
|
Observable<T> |
Observable.onBackpressureBuffer(long capacity)
Instructs an Observable that is emitting items faster than its observer can consume them to buffer up to
a given amount of items until they can be emitted.
|
Observable<T> |
Observable.onBackpressureBuffer(long capacity,
Action0 onOverflow)
Instructs an Observable that is emitting items faster than its observer can consume them to buffer up to
a given amount of items until they can be emitted.
|
Observable<T> |
Observable.onBackpressureDrop()
Instructs an Observable that is emitting items faster than its observer can consume them to discard,
rather than emit, those items that its observer is not prepared to observe.
|
Observable<T> |
Observable.onBackpressureDrop(Action1<? super T> onDrop)
Instructs an Observable that is emitting items faster than its observer can consume them to discard,
rather than emit, those items that its observer is not prepared to observe.
|
Observable<T> |
Observable.onBackpressureLatest()
Instructs an Observable that is emitting items faster than its observer can consume them to
hold onto the latest value and emit that on request.
|
Observable<T> |
Observable.onErrorResumeNext(Func1<Throwable,? extends Observable<? extends T>> resumeFunction)
Instructs an Observable to pass control to another Observable rather than invoking
onError if it encounters an error. |
Observable<T> |
Observable.onErrorResumeNext(Observable<? extends T> resumeSequence)
Instructs an Observable to pass control to another Observable rather than invoking
onError if it encounters an error. |
Observable<T> |
Observable.onErrorReturn(Func1<Throwable,? extends T> resumeFunction)
Instructs an Observable to emit an item (returned by a specified function) rather than invoking
onError if it encounters an error. |
Observable<T> |
Observable.onExceptionResumeNext(Observable<? extends T> resumeSequence)
|
<R> Observable<R> |
Observable.publish(Func1<? super Observable<T>,? extends Observable<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. |
static Observable<Integer> |
Observable.range(int start,
int count)
Returns an Observable that emits a sequence of Integers within a specified range.
|
static Observable<Integer> |
Observable.range(int start,
int count,
Scheduler scheduler)
Returns an Observable that emits a sequence of Integers within a specified range, on a specified
Scheduler.
|
Observable<T> |
Observable.reduce(Func2<T,T,T> accumulator)
Returns an Observable that applies a specified accumulator function to the first item emitted by a source
Observable, then feeds the result of that function along with the second item emitted by the source
Observable into the same function, and so on until all items have been emitted by the source Observable,
and emits the final result from the final call to your function as its sole item.
|
<R> Observable<R> |
Observable.reduce(R initialValue,
Func2<R,? super T,R> accumulator)
Returns an Observable that applies a specified accumulator function to the first item emitted by a source
Observable and a specified seed value, then feeds the result of that function along with the second item
emitted by an Observable into the same function, and so on until all items have been emitted by the
source Observable, emitting the final result from the final call to your function as its sole item.
|
Observable<T> |
Observable.repeat()
Returns an Observable that repeats the sequence of items emitted by the source Observable indefinitely.
|
Observable<T> |
Observable.repeat(long count)
Returns an Observable that repeats the sequence of items emitted by the source Observable at most
count times. |
Observable<T> |
Observable.repeat(long count,
Scheduler scheduler)
Returns an Observable that repeats the sequence of items emitted by the source Observable at most
count times, on a particular Scheduler. |
Observable<T> |
Observable.repeat(Scheduler scheduler)
Returns an Observable that repeats the sequence of items emitted by the source Observable indefinitely,
on a particular Scheduler.
|
Observable<T> |
Observable.repeatWhen(Func1<? super Observable<? extends Void>,? extends Observable<?>> notificationHandler)
Returns an Observable that emits the same values as the source Observable with the exception of an
onCompleted . |
Observable<T> |
Observable.repeatWhen(Func1<? super Observable<? extends Void>,? extends Observable<?>> notificationHandler,
Scheduler scheduler)
Returns an Observable that emits the same values as the source Observable with the exception of an
onCompleted . |
<R> Observable<R> |
Observable.replay(Func1<? super Observable<T>,? extends Observable<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 Observable. |
<R> Observable<R> |
Observable.replay(Func1<? super Observable<T>,? extends Observable<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 Observable,
replaying bufferSize notifications. |
<R> Observable<R> |
Observable.replay(Func1<? super Observable<T>,? extends Observable<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 Observable,
replaying no more than bufferSize items that were emitted within a specified time window. |
<R> Observable<R> |
Observable.replay(Func1<? super Observable<T>,? extends Observable<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 Observable,
replaying no more than bufferSize items that were emitted within a specified time window. |
<R> Observable<R> |
Observable.replay(Func1<? super Observable<T>,? extends Observable<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 Observable,
replaying a maximum of bufferSize items. |
<R> Observable<R> |
Observable.replay(Func1<? super Observable<T>,? extends Observable<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 Observable,
replaying all items that were emitted within a specified time window. |
<R> Observable<R> |
Observable.replay(Func1<? super Observable<T>,? extends Observable<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 Observable,
replaying all items that were emitted within a specified time window. |
<R> Observable<R> |
Observable.replay(Func1<? super Observable<T>,? extends Observable<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 Observable. |
Observable<T> |
Observable.retry()
Returns an Observable that mirrors the source Observable, resubscribing to it if it calls
onError
(infinite retry count). |
Observable<T> |
Observable.retry(Func2<Integer,Throwable,Boolean> predicate)
Returns an Observable that mirrors the source Observable, resubscribing to it if it calls
onError
and the predicate returns true for that specific exception and retry count. |
Observable<T> |
Observable.retry(long count)
Returns an Observable that mirrors the source Observable, resubscribing to it if it calls
onError
up to a specified number of retries. |
Observable<T> |
Observable.retryWhen(Func1<? super Observable<? extends Throwable>,? extends Observable<?>> notificationHandler)
Returns an Observable that emits the same values as the source observable with the exception of an
onError . |
Observable<T> |
Observable.retryWhen(Func1<? super Observable<? extends Throwable>,? extends Observable<?>> notificationHandler,
Scheduler scheduler)
Returns an Observable that emits the same values as the source observable with the exception of an
onError . |
Observable<T> |
Observable.sample(long period,
TimeUnit unit)
Returns an Observable that emits the most recently emitted item (if any) emitted by the source Observable
within periodic time intervals.
|
Observable<T> |
Observable.sample(long period,
TimeUnit unit,
Scheduler scheduler)
Returns an Observable that emits the most recently emitted item (if any) emitted by the source Observable
within periodic time intervals, where the intervals are defined on a particular Scheduler.
|
<U> Observable<T> |
Observable.sample(Observable<U> sampler)
Returns an Observable that, when the specified
sampler Observable emits an item or completes,
emits the most recently emitted item (if any) emitted by the source Observable since the previous
emission from the sampler Observable. |
Observable<T> |
Observable.scan(Func2<T,T,T> accumulator)
Returns an Observable that applies a specified accumulator function to the first item emitted by a source
Observable, then feeds the result of that function along with the second item emitted by the source
Observable into the same function, and so on until all items have been emitted by the source Observable,
emitting the result of each of these iterations.
|
<R> Observable<R> |
Observable.scan(R initialValue,
Func2<R,? super T,R> accumulator)
Returns an Observable that applies a specified accumulator function to the first item emitted by a source
Observable and a seed value, then feeds the result of that function along with the second item emitted by
the source Observable into the same function, and so on until all items have been emitted by the source
Observable, emitting the result of each of these iterations.
|
static <T> Observable<Boolean> |
Observable.sequenceEqual(Observable<? extends T> first,
Observable<? extends T> second)
Returns an Observable that emits a Boolean value that indicates whether two Observable sequences are the
same by comparing the items emitted by each Observable pairwise.
|
static <T> Observable<Boolean> |
Observable.sequenceEqual(Observable<? extends T> first,
Observable<? extends T> second,
Func2<? super T,? super T,Boolean> equality)
Returns an Observable that emits a Boolean value that indicates whether two Observable sequences are the
same by comparing the items emitted by each Observable pairwise based on the results of a specified
equality function.
|
Observable<T> |
Observable.serialize()
Forces an Observable's emissions and notifications to be serialized and for it to obey the Rx contract
in other ways.
|
Observable<T> |
Observable.share()
Returns a new
Observable that multicasts (shares) the original Observable . |
Observable<T> |
Observable.single()
Returns an Observable that emits the single item emitted by the source Observable, if that Observable
emits only a single item.
|
Observable<T> |
Observable.single(Func1<? super T,Boolean> predicate)
Returns an Observable that emits the single item emitted by the source Observable that matches a
specified predicate, if that Observable emits one such item.
|
Observable<T> |
Observable.singleOrDefault(T defaultValue)
Returns an Observable that emits the single item emitted by the source Observable, if that Observable
emits only a single item, or a default item if the source Observable emits no items.
|
Observable<T> |
Observable.singleOrDefault(T defaultValue,
Func1<? super T,Boolean> predicate)
Returns an Observable that emits the single item emitted by the source Observable that matches a
predicate, if that Observable emits only one such item, or a default item if the source Observable emits
no such items.
|
Observable<T> |
Observable.skip(int count)
Returns an Observable that skips the first
count items emitted by the source Observable and emits
the remainder. |
Observable<T> |
Observable.skip(long time,
TimeUnit unit)
Returns an Observable that skips values emitted by the source Observable before a specified time window
elapses.
|
Observable<T> |
Observable.skip(long time,
TimeUnit unit,
Scheduler scheduler)
Returns an Observable that skips values emitted by the source Observable before a specified time window
on a specified
Scheduler elapses. |
Observable<T> |
Observable.skipLast(int count)
Returns an Observable that drops a specified number of items from the end of the sequence emitted by the
source Observable.
|
Observable<T> |
Observable.skipLast(long time,
TimeUnit unit)
Returns an Observable that drops items emitted by the source Observable during a specified time window
before the source completes.
|
Observable<T> |
Observable.skipLast(long time,
TimeUnit unit,
Scheduler scheduler)
Returns an Observable that drops items emitted by the source Observable during a specified time window
(defined on a specified scheduler) before the source completes.
|
<U> Observable<T> |
Observable.skipUntil(Observable<U> other)
Returns an Observable that skips items emitted by the source Observable until a second Observable emits
an item.
|
Observable<T> |
Observable.skipWhile(Func1<? super T,Boolean> predicate)
Returns an Observable that skips all items emitted by the source Observable as long as a specified
condition holds true, but emits all further source items as soon as the condition becomes false.
|
Observable<T> |
Observable.startWith(Iterable<T> values)
Returns an Observable that emits the items in a specified
Iterable before it begins to emit items
emitted by the source Observable. |
Observable<T> |
Observable.startWith(Observable<T> values)
Returns an Observable that emits the items in a specified
Observable before it begins to emit
items emitted by the source Observable. |
Observable<T> |
Observable.startWith(T t1)
Returns an Observable that emits a specified item before it begins to emit items emitted by the source
Observable.
|
Observable<T> |
Observable.startWith(T t1,
T t2)
Returns an Observable that emits the specified items before it begins to emit items emitted by the source
Observable.
|
Observable<T> |
Observable.startWith(T t1,
T t2,
T t3)
Returns an Observable that emits the specified items before it begins to emit items emitted by the source
Observable.
|
Observable<T> |
Observable.startWith(T t1,
T t2,
T t3,
T t4)
Returns an Observable that emits the specified items before it begins to emit items emitted by the source
Observable.
|
Observable<T> |
Observable.startWith(T t1,
T t2,
T t3,
T t4,
T t5)
Returns an Observable that emits the specified items before it begins to emit items emitted by the source
Observable.
|
Observable<T> |
Observable.startWith(T t1,
T t2,
T t3,
T t4,
T t5,
T t6)
Returns an Observable that emits the specified items before it begins to emit items emitted by the source
Observable.
|
Observable<T> |
Observable.startWith(T t1,
T t2,
T t3,
T t4,
T t5,
T t6,
T t7)
Returns an Observable that emits the specified items before it begins to emit items emitted by the source
Observable.
|
Observable<T> |
Observable.startWith(T t1,
T t2,
T t3,
T t4,
T t5,
T t6,
T t7,
T t8)
Returns an Observable that emits the specified items before it begins to emit items emitted by the source
Observable.
|
Observable<T> |
Observable.startWith(T t1,
T t2,
T t3,
T t4,
T t5,
T t6,
T t7,
T t8,
T t9)
Returns an Observable that emits the specified items before it begins to emit items emitted by the source
Observable.
|
Observable<T> |
Observable.subscribeOn(Scheduler scheduler)
Asynchronously subscribes Observers to this Observable on the specified
Scheduler . |
Observable<T> |
Observable.switchIfEmpty(Observable<? extends T> alternate)
Returns an Observable that emits the items emitted by the source Observable or the items of an alternate
Observable if the source Observable is empty.
|
<R> Observable<R> |
Observable.switchMap(Func1<? super T,? extends Observable<? extends R>> func)
Returns a new Observable by applying a function that you supply to each item emitted by the source
Observable that returns an Observable, and then emitting the items emitted by the most recently emitted
of these Observables.
|
static <T> Observable<T> |
Observable.switchOnNext(Observable<? extends Observable<? extends T>> sequenceOfSequences)
Converts an Observable that emits Observables into an Observable that emits the items emitted by the
most recently emitted of those Observables.
|
Observable<T> |
Observable.take(int count)
Returns an Observable that emits only the first
count items emitted by the source Observable. |
Observable<T> |
Observable.take(long time,
TimeUnit unit)
Returns an Observable that emits those items emitted by source Observable before a specified time runs
out.
|
Observable<T> |
Observable.take(long time,
TimeUnit unit,
Scheduler scheduler)
Returns an Observable that emits those items emitted by source Observable before a specified time (on a
specified Scheduler) runs out.
|
Observable<T> |
Observable.takeFirst(Func1<? super T,Boolean> predicate)
Returns an Observable that emits only the very first item emitted by the source Observable that satisfies
a specified condition.
|
Observable<T> |
Observable.takeLast(int count)
Returns an Observable that emits at most the last
count items emitted by the source Observable. |
Observable<T> |
Observable.takeLast(int count,
long time,
TimeUnit unit)
Returns an Observable that emits at most a specified number of items from the source Observable that were
emitted in a specified window of time before the Observable completed.
|
Observable<T> |
Observable.takeLast(int count,
long time,
TimeUnit unit,
Scheduler scheduler)
Returns an Observable that emits at most a specified number of items from the source Observable that were
emitted in a specified window of time before the Observable completed, where the timing information is
provided by a given Scheduler.
|
Observable<T> |
Observable.takeLast(long time,
TimeUnit unit)
Returns an Observable that emits the items from the source Observable that were emitted in a specified
window of time before the Observable completed.
|
Observable<T> |
Observable.takeLast(long time,
TimeUnit unit,
Scheduler scheduler)
Returns an Observable that emits the items from the source Observable that were emitted in a specified
window of time before the Observable completed, where the timing information is provided by a specified
Scheduler.
|
Observable<List<T>> |
Observable.takeLastBuffer(int count)
Returns an Observable that emits a single List containing at most the last
count elements emitted by the
source Observable. |
Observable<List<T>> |
Observable.takeLastBuffer(int count,
long time,
TimeUnit unit)
Returns an Observable that emits a single List containing at most
count items from the source
Observable that were emitted during a specified window of time before the source Observable completed. |
Observable<List<T>> |
Observable.takeLastBuffer(int count,
long time,
TimeUnit unit,
Scheduler scheduler)
Returns an Observable that emits a single List containing at most
count items from the source
Observable that were emitted during a specified window of time (on a specified Scheduler) before the
source Observable completed. |
Observable<List<T>> |
Observable.takeLastBuffer(long time,
TimeUnit unit)
Returns an Observable that emits a single List containing those items from the source Observable that
were emitted during a specified window of time before the source Observable completed.
|
Observable<List<T>> |
Observable.takeLastBuffer(long time,
TimeUnit unit,
Scheduler scheduler)
Returns an Observable that emits a single List containing those items from the source Observable that
were emitted during a specified window of time before the source Observable completed, where the timing
information is provided by the given Scheduler.
|
Observable<T> |
Observable.takeUntil(Func1<? super T,Boolean> stopPredicate)
Returns an Observable that emits items emitted by the source Observable, checks the specified predicate
for each item, and then completes if the condition is satisfied.
|
<E> Observable<T> |
Observable.takeUntil(Observable<? extends E> other)
Returns an Observable that emits the items emitted by the source Observable until a second Observable
emits an item.
|
Observable<T> |
Observable.takeWhile(Func1<? super T,Boolean> predicate)
Returns an Observable that emits items emitted by the source Observable so long as each item satisfied a
specified condition, and then completes as soon as this condition is not satisfied.
|
Observable<T> |
Observable.throttleFirst(long windowDuration,
TimeUnit unit)
Returns an Observable that emits only the first item emitted by the source Observable during sequential
time windows of a specified duration.
|
Observable<T> |
Observable.throttleFirst(long skipDuration,
TimeUnit unit,
Scheduler scheduler)
Returns an Observable that emits only the first item emitted by the source Observable during sequential
time windows of a specified duration, where the windows are managed by a specified Scheduler.
|
Observable<T> |
Observable.throttleLast(long intervalDuration,
TimeUnit unit)
Returns an Observable that emits only the last item emitted by the source Observable during sequential
time windows of a specified duration.
|
Observable<T> |
Observable.throttleLast(long intervalDuration,
TimeUnit unit,
Scheduler scheduler)
Returns an Observable that emits only the last item emitted by the source Observable during sequential
time windows of a specified duration, where the duration is governed by a specified Scheduler.
|
Observable<T> |
Observable.throttleWithTimeout(long timeout,
TimeUnit unit)
Returns an Observable that only emits those items emitted by the source Observable that are not followed
by another emitted item within a specified time window.
|
Observable<T> |
Observable.throttleWithTimeout(long timeout,
TimeUnit unit,
Scheduler scheduler)
Returns an Observable that only emits those items emitted by the source Observable that are not followed
by another emitted item within a specified time window, where the time window is governed by a specified
Scheduler.
|
Observable<TimeInterval<T>> |
Observable.timeInterval()
Returns an Observable that emits records of the time interval between consecutive items emitted by the
source Observable.
|
Observable<TimeInterval<T>> |
Observable.timeInterval(Scheduler scheduler)
Returns an Observable that emits records of the time interval between consecutive items emitted by the
source Observable, where this interval is computed on a specified Scheduler.
|
<U,V> Observable<T> |
Observable.timeout(Func0<? extends Observable<U>> firstTimeoutSelector,
Func1<? super T,? extends Observable<V>> timeoutSelector)
Returns an Observable that mirrors the source Observable, but notifies observers of a
TimeoutException if either the first item emitted by the source Observable or any subsequent item
doesn't arrive within time windows defined by other Observables. |
<U,V> Observable<T> |
Observable.timeout(Func0<? extends Observable<U>> firstTimeoutSelector,
Func1<? super T,? extends Observable<V>> timeoutSelector,
Observable<? extends T> other)
Returns an Observable that mirrors the source Observable, but switches to a fallback Observable if either
the first item emitted by the source Observable or any subsequent item doesn't arrive within time windows
defined by other Observables.
|
<V> Observable<T> |
Observable.timeout(Func1<? super T,? extends Observable<V>> timeoutSelector)
Returns an Observable that mirrors the source Observable, but notifies observers of a
TimeoutException if an item emitted by the source Observable doesn't arrive within a window of
time after the emission of the previous item, where that period of time is measured by an Observable that
is a function of the previous item. |
<V> Observable<T> |
Observable.timeout(Func1<? super T,? extends Observable<V>> timeoutSelector,
Observable<? extends T> other)
Returns an Observable that mirrors the source Observable, but that switches to a fallback Observable if
an item emitted by the source Observable doesn't arrive within a window of time after the emission of the
previous item, where that period of time is measured by an Observable that is a function of the previous
item.
|
Observable<T> |
Observable.timeout(long timeout,
TimeUnit timeUnit)
Returns an Observable that mirrors the source Observable but applies a timeout policy for each emitted
item.
|
Observable<T> |
Observable.timeout(long timeout,
TimeUnit timeUnit,
Observable<? extends T> other)
Returns an Observable that mirrors the source Observable but applies a timeout policy for each emitted
item.
|
Observable<T> |
Observable.timeout(long timeout,
TimeUnit timeUnit,
Observable<? extends T> other,
Scheduler scheduler)
Returns an Observable that mirrors the source Observable but applies a timeout policy for each emitted
item using a specified Scheduler.
|
Observable<T> |
Observable.timeout(long timeout,
TimeUnit timeUnit,
Scheduler scheduler)
Returns an Observable that mirrors the source Observable but applies a timeout policy for each emitted
item, where this policy is governed on a specified Scheduler.
|
static Observable<Long> |
Observable.timer(long initialDelay,
long period,
TimeUnit unit)
Deprecated.
use
interval(long, long, TimeUnit) instead |
static Observable<Long> |
Observable.timer(long initialDelay,
long period,
TimeUnit unit,
Scheduler scheduler)
Deprecated.
use
interval(long, long, TimeUnit, Scheduler) instead |
static Observable<Long> |
Observable.timer(long delay,
TimeUnit unit)
Returns an Observable that emits one item after a specified delay, and then completes.
|
static Observable<Long> |
Observable.timer(long delay,
TimeUnit unit,
Scheduler scheduler)
Returns an Observable that emits one item after a specified delay, on a specified Scheduler, and then
completes.
|
Observable<Timestamped<T>> |
Observable.timestamp()
Returns an Observable that emits each item emitted by the source Observable, wrapped in a
Timestamped object. |
Observable<Timestamped<T>> |
Observable.timestamp(Scheduler scheduler)
Returns an Observable that emits each item emitted by the source Observable, wrapped in a
Timestamped object whose timestamps are provided by a specified Scheduler. |
Observable<List<T>> |
Observable.toList()
Returns an Observable that emits a single item, a list composed of all the items emitted by the source
Observable.
|
<K> Observable<Map<K,T>> |
Observable.toMap(Func1<? super T,? extends K> keySelector)
Returns an Observable that emits a single HashMap containing all items emitted by the source Observable,
mapped by the keys returned by a specified
keySelector function. |
<K,V> Observable<Map<K,V>> |
Observable.toMap(Func1<? super T,? extends K> keySelector,
Func1<? super T,? extends V> valueSelector)
Returns an Observable that emits a single HashMap containing values corresponding to items emitted by the
source Observable, mapped by the keys returned by a specified
keySelector function. |
<K,V> Observable<Map<K,V>> |
Observable.toMap(Func1<? super T,? extends K> keySelector,
Func1<? super T,? extends V> valueSelector,
Func0<? extends Map<K,V>> mapFactory)
Returns an Observable that emits a single Map, returned by a specified
mapFactory function, that
contains keys and values extracted from the items emitted by the source Observable. |
<K> Observable<Map<K,Collection<T>>> |
Observable.toMultimap(Func1<? super T,? extends K> keySelector)
Returns an Observable that emits a single HashMap that contains an ArrayList of items emitted by the
source Observable keyed by a specified
keySelector function. |
<K,V> Observable<Map<K,Collection<V>>> |
Observable.toMultimap(Func1<? super T,? extends K> keySelector,
Func1<? super T,? extends V> valueSelector)
Returns an Observable that emits a single HashMap that contains an ArrayList of values extracted by a
specified
valueSelector function from items emitted by the source Observable, keyed by a
specified keySelector function. |
<K,V> Observable<Map<K,Collection<V>>> |
Observable.toMultimap(Func1<? super T,? extends K> keySelector,
Func1<? super T,? extends V> valueSelector,
Func0<? extends Map<K,Collection<V>>> mapFactory)
Returns an Observable that emits a single Map, returned by a specified
mapFactory function, that
contains an ArrayList of values, extracted by a specified valueSelector function from items
emitted by the source Observable and keyed by the keySelector function. |
<K,V> Observable<Map<K,Collection<V>>> |
Observable.toMultimap(Func1<? super T,? extends K> keySelector,
Func1<? super T,? extends V> valueSelector,
Func0<? extends Map<K,Collection<V>>> mapFactory,
Func1<? super K,? extends Collection<V>> collectionFactory)
Returns an Observable that emits a single Map, returned by a specified
mapFactory function, that
contains a custom collection of values, extracted by a specified valueSelector function from
items emitted by the source Observable, and keyed by the keySelector function. |
Observable<T> |
Single.toObservable()
Converts this Single into an
Observable . |
Observable<List<T>> |
Observable.toSortedList()
Returns an Observable that emits a list that contains the items emitted by the source Observable, in a
sorted order.
|
Observable<List<T>> |
Observable.toSortedList(Func2<? super T,? super T,Integer> sortFunction)
Returns an Observable that emits a list that contains the items emitted by the source Observable, in a
sorted order based on a specified comparison function.
|
Observable<List<T>> |
Observable.toSortedList(Func2<? super T,? super T,Integer> sortFunction,
int initialCapacity)
Returns an Observable that emits a list that contains the items emitted by the source Observable, in a
sorted order based on a specified comparison function.
|
Observable<List<T>> |
Observable.toSortedList(int initialCapacity)
Returns an Observable that emits a list that contains the items emitted by the source Observable, in a
sorted order.
|
Observable<T> |
Observable.unsubscribeOn(Scheduler scheduler)
Modifies the source Observable so that subscribers will unsubscribe from it on a specified
Scheduler . |
static <T,Resource> |
Observable.using(Func0<Resource> resourceFactory,
Func1<? super Resource,? extends Observable<? extends T>> observableFactory,
Action1<? super Resource> disposeAction)
Constructs an Observable that creates a dependent resource object which is disposed of on unsubscription.
|
static <T,Resource> |
Observable.using(Func0<Resource> resourceFactory,
Func1<? super Resource,? extends Observable<? extends T>> observableFactory,
Action1<? super Resource> disposeAction,
boolean disposeEagerly)
Constructs an Observable that creates a dependent resource object which is disposed of just before
termination if you have set
disposeEagerly to true and unsubscription does not occur
before termination. |
<TClosing> Observable<Observable<T>> |
Observable.window(Func0<? extends Observable<? extends TClosing>> closingSelector)
Returns an Observable that emits windows of items it collects from the source Observable.
|
Observable<Observable<T>> |
Observable.window(int count)
Returns an Observable that emits windows of items it collects from the source Observable.
|
Observable<Observable<T>> |
Observable.window(int count,
int skip)
Returns an Observable that emits windows of items it collects from the source Observable.
|
Observable<Observable<T>> |
Observable.window(long timespan,
long timeshift,
TimeUnit unit)
Returns an Observable that emits windows of items it collects from the source Observable.
|
Observable<Observable<T>> |
Observable.window(long timespan,
long timeshift,
TimeUnit unit,
int count,
Scheduler scheduler)
Returns an Observable that emits windows of items it collects from the source Observable.
|
Observable<Observable<T>> |
Observable.window(long timespan,
long timeshift,
TimeUnit unit,
Scheduler scheduler)
Returns an Observable that emits windows of items it collects from the source Observable.
|
Observable<Observable<T>> |
Observable.window(long timespan,
TimeUnit unit)
Returns an Observable that emits windows of items it collects from the source Observable.
|
Observable<Observable<T>> |
Observable.window(long timespan,
TimeUnit unit,
int count)
Returns an Observable that emits windows of items it collects from the source Observable.
|
Observable<Observable<T>> |
Observable.window(long timespan,
TimeUnit unit,
int count,
Scheduler scheduler)
Returns an Observable that emits windows of items it collects from the source Observable.
|
Observable<Observable<T>> |
Observable.window(long timespan,
TimeUnit unit,
Scheduler scheduler)
Returns an Observable that emits windows of items it collects from the source Observable.
|
<TOpening,TClosing> |
Observable.window(Observable<? extends TOpening> windowOpenings,
Func1<? super TOpening,? extends Observable<? extends TClosing>> closingSelector)
Returns an Observable that emits windows of items it collects from the source Observable.
|
<U> Observable<Observable<T>> |
Observable.window(Observable<U> boundary)
Returns an Observable that emits non-overlapping windows of items it collects from the source Observable
where the boundary of each window is determined by the items emitted from a specified boundary-governing
Observable.
|
<U,R> Observable<R> |
Observable.withLatestFrom(Observable<? extends U> other,
Func2<? super T,? super U,? extends R> resultSelector)
Merges the specified Observable into this Observable sequence by using the
resultSelector
function only when the source Observable (this instance) emits an item. |
static <R> Observable<R> |
Observable.zip(Iterable<? extends Observable<?>> ws,
FuncN<? extends R> zipFunction)
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 Observables.
|
static <R> Observable<R> |
Observable.zip(Observable<? extends Observable<?>> ws,
FuncN<? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
n items emitted, in sequence, by the n Observables emitted by a specified Observable.
|
static <T1,T2,R> Observable<R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Func2<? super T1,? super T2,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
two items emitted, in sequence, by two other Observables.
|
static <T1,T2,T3,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Func3<? super T1,? super T2,? super T3,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
three items emitted, in sequence, by three other Observables.
|
static <T1,T2,T3,T4,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Func4<? super T1,? super T2,? super T3,? super T4,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
four items emitted, in sequence, by four other Observables.
|
static <T1,T2,T3,T4,T5,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Func5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
five items emitted, in sequence, by five other Observables.
|
static <T1,T2,T3,T4,T5,T6,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Func6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
six items emitted, in sequence, by six other Observables.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Func7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
seven items emitted, in sequence, by seven other Observables.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Func8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
eight items emitted, in sequence, by eight other Observables.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Observable<? extends T9> o9,
Func9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
nine items emitted, in sequence, by nine other Observables.
|
<T2,R> Observable<R> |
Observable.zipWith(Iterable<? extends T2> other,
Func2<? super T,? super T2,? extends R> zipFunction)
Returns an Observable that emits items that are the result of applying a specified function to pairs of
values, one each from the source Observable and a specified Iterable sequence.
|
<T2,R> Observable<R> |
Observable.zipWith(Observable<? extends T2> other,
Func2<? super T,? super T2,? extends R> zipFunction)
Returns an Observable that emits items that are the result of applying a specified function to pairs of
values, one each from the source Observable and another specified Observable.
|
Modifier and Type | Method and Description |
---|---|
Observable<Observable<T>> |
Observable.nest()
Converts the source
Observable<T> into an Observable<Observable<T>> that emits the
source Observable as its single emission. |
<TClosing> Observable<Observable<T>> |
Observable.window(Func0<? extends Observable<? extends TClosing>> closingSelector)
Returns an Observable that emits windows of items it collects from the source Observable.
|
Observable<Observable<T>> |
Observable.window(int count)
Returns an Observable that emits windows of items it collects from the source Observable.
|
Observable<Observable<T>> |
Observable.window(int count,
int skip)
Returns an Observable that emits windows of items it collects from the source Observable.
|
Observable<Observable<T>> |
Observable.window(long timespan,
long timeshift,
TimeUnit unit)
Returns an Observable that emits windows of items it collects from the source Observable.
|
Observable<Observable<T>> |
Observable.window(long timespan,
long timeshift,
TimeUnit unit,
int count,
Scheduler scheduler)
Returns an Observable that emits windows of items it collects from the source Observable.
|
Observable<Observable<T>> |
Observable.window(long timespan,
long timeshift,
TimeUnit unit,
Scheduler scheduler)
Returns an Observable that emits windows of items it collects from the source Observable.
|
Observable<Observable<T>> |
Observable.window(long timespan,
TimeUnit unit)
Returns an Observable that emits windows of items it collects from the source Observable.
|
Observable<Observable<T>> |
Observable.window(long timespan,
TimeUnit unit,
int count)
Returns an Observable that emits windows of items it collects from the source Observable.
|
Observable<Observable<T>> |
Observable.window(long timespan,
TimeUnit unit,
int count,
Scheduler scheduler)
Returns an Observable that emits windows of items it collects from the source Observable.
|
Observable<Observable<T>> |
Observable.window(long timespan,
TimeUnit unit,
Scheduler scheduler)
Returns an Observable that emits windows of items it collects from the source Observable.
|
<TOpening,TClosing> |
Observable.window(Observable<? extends TOpening> windowOpenings,
Func1<? super TOpening,? extends Observable<? extends TClosing>> closingSelector)
Returns an Observable that emits windows of items it collects from the source Observable.
|
<U> Observable<Observable<T>> |
Observable.window(Observable<U> boundary)
Returns an Observable that emits non-overlapping windows of items it collects from the source Observable
where the boundary of each window is determined by the items emitted from a specified boundary-governing
Observable.
|
Modifier and Type | Method and Description |
---|---|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2)
Given two Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2)
Given two Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3)
Given three Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3)
Given three Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3)
Given three Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4)
Given four Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4)
Given four Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4)
Given four Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4)
Given four Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5)
Given five Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5)
Given five Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5)
Given five Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5)
Given five Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5)
Given five Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6)
Given six Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6)
Given six Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6)
Given six Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6)
Given six Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6)
Given six Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6)
Given six Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6,
Observable<? extends T> o7)
Given seven Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6,
Observable<? extends T> o7)
Given seven Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6,
Observable<? extends T> o7)
Given seven Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6,
Observable<? extends T> o7)
Given seven Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6,
Observable<? extends T> o7)
Given seven Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6,
Observable<? extends T> o7)
Given seven Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6,
Observable<? extends T> o7)
Given seven Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6,
Observable<? extends T> o7,
Observable<? extends T> o8)
Given eight Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6,
Observable<? extends T> o7,
Observable<? extends T> o8)
Given eight Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6,
Observable<? extends T> o7,
Observable<? extends T> o8)
Given eight Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6,
Observable<? extends T> o7,
Observable<? extends T> o8)
Given eight Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6,
Observable<? extends T> o7,
Observable<? extends T> o8)
Given eight Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6,
Observable<? extends T> o7,
Observable<? extends T> o8)
Given eight Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6,
Observable<? extends T> o7,
Observable<? extends T> o8)
Given eight Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6,
Observable<? extends T> o7,
Observable<? extends T> o8)
Given eight Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6,
Observable<? extends T> o7,
Observable<? extends T> o8,
Observable<? extends T> o9)
Given nine Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6,
Observable<? extends T> o7,
Observable<? extends T> o8,
Observable<? extends T> o9)
Given nine Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6,
Observable<? extends T> o7,
Observable<? extends T> o8,
Observable<? extends T> o9)
Given nine Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6,
Observable<? extends T> o7,
Observable<? extends T> o8,
Observable<? extends T> o9)
Given nine Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6,
Observable<? extends T> o7,
Observable<? extends T> o8,
Observable<? extends T> o9)
Given nine Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6,
Observable<? extends T> o7,
Observable<? extends T> o8,
Observable<? extends T> o9)
Given nine Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6,
Observable<? extends T> o7,
Observable<? extends T> o8,
Observable<? extends T> o9)
Given nine Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6,
Observable<? extends T> o7,
Observable<? extends T> o8,
Observable<? extends T> o9)
Given nine Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
static <T> Observable<T> |
Observable.amb(Observable<? extends T> o1,
Observable<? extends T> o2,
Observable<? extends T> o3,
Observable<? extends T> o4,
Observable<? extends T> o5,
Observable<? extends T> o6,
Observable<? extends T> o7,
Observable<? extends T> o8,
Observable<? extends T> o9)
Given nine Observables, mirrors the one that first either emits an item or sends a termination
notification.
|
Observable<T> |
Observable.ambWith(Observable<? extends T> t1)
Mirrors the Observable (current or provided) that first either emits an item or sends a termination
notification.
|
<TOpening,TClosing> |
Observable.buffer(Observable<? extends TOpening> bufferOpenings,
Func1<? super TOpening,? extends Observable<? extends TClosing>> bufferClosingSelector)
Returns an Observable that emits buffers of items it collects from the source Observable.
|
<B> Observable<List<T>> |
Observable.buffer(Observable<B> boundary)
Returns an Observable that emits non-overlapping buffered items from the source Observable each time the
specified boundary Observable emits an item.
|
<B> Observable<List<T>> |
Observable.buffer(Observable<B> boundary,
int initialCapacity)
Returns an Observable that emits non-overlapping buffered items from the source Observable each time the
specified boundary Observable emits an item.
|
static <T1,T2,R> Observable<R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Func2<? super T1,? super T2,? extends R> combineFunction)
Combines two source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from either of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,R> Observable<R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Func2<? super T1,? super T2,? extends R> combineFunction)
Combines two source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from either of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Func3<? super T1,? super T2,? super T3,? extends R> combineFunction)
Combines three source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Func3<? super T1,? super T2,? super T3,? extends R> combineFunction)
Combines three source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Func3<? super T1,? super T2,? super T3,? extends R> combineFunction)
Combines three source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Func4<? super T1,? super T2,? super T3,? super T4,? extends R> combineFunction)
Combines four source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Func4<? super T1,? super T2,? super T3,? super T4,? extends R> combineFunction)
Combines four source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Func4<? super T1,? super T2,? super T3,? super T4,? extends R> combineFunction)
Combines four source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Func4<? super T1,? super T2,? super T3,? super T4,? extends R> combineFunction)
Combines four source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Func5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> combineFunction)
Combines five source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Func5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> combineFunction)
Combines five source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Func5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> combineFunction)
Combines five source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Func5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> combineFunction)
Combines five source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Func5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> combineFunction)
Combines five source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Func6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> combineFunction)
Combines six source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Func6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> combineFunction)
Combines six source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Func6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> combineFunction)
Combines six source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Func6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> combineFunction)
Combines six source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Func6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> combineFunction)
Combines six source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Func6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> combineFunction)
Combines six source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Func7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> combineFunction)
Combines seven source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Func7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> combineFunction)
Combines seven source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Func7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> combineFunction)
Combines seven source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Func7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> combineFunction)
Combines seven source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Func7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> combineFunction)
Combines seven source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Func7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> combineFunction)
Combines seven source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Func7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> combineFunction)
Combines seven source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Func8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> combineFunction)
Combines eight source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Func8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> combineFunction)
Combines eight source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Func8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> combineFunction)
Combines eight source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Func8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> combineFunction)
Combines eight source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Func8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> combineFunction)
Combines eight source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Func8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> combineFunction)
Combines eight source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Func8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> combineFunction)
Combines eight source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Func8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> combineFunction)
Combines eight source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Observable<? extends T9> o9,
Func9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> combineFunction)
Combines nine source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Observable<? extends T9> o9,
Func9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> combineFunction)
Combines nine source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Observable<? extends T9> o9,
Func9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> combineFunction)
Combines nine source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Observable<? extends T9> o9,
Func9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> combineFunction)
Combines nine source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Observable<? extends T9> o9,
Func9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> combineFunction)
Combines nine source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Observable<? extends T9> o9,
Func9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> combineFunction)
Combines nine source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Observable<? extends T9> o9,
Func9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> combineFunction)
Combines nine source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Observable<? extends T9> o9,
Func9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> combineFunction)
Combines nine source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Observable<? extends T9> o9,
Func9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> combineFunction)
Combines nine source Observables by emitting an item that aggregates the latest values of each of the
source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends Observable<? extends T>> observables)
Returns an Observable that emits the items emitted by each of the Observables emitted by the source
Observable, one after the other, without interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2)
Returns an Observable that emits the items emitted by two Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2)
Returns an Observable that emits the items emitted by two Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3)
Returns an Observable that emits the items emitted by three Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3)
Returns an Observable that emits the items emitted by three Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3)
Returns an Observable that emits the items emitted by three Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4)
Returns an Observable that emits the items emitted by four Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4)
Returns an Observable that emits the items emitted by four Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4)
Returns an Observable that emits the items emitted by four Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4)
Returns an Observable that emits the items emitted by four Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5)
Returns an Observable that emits the items emitted by five Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5)
Returns an Observable that emits the items emitted by five Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5)
Returns an Observable that emits the items emitted by five Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5)
Returns an Observable that emits the items emitted by five Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5)
Returns an Observable that emits the items emitted by five Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6)
Returns an Observable that emits the items emitted by six Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6)
Returns an Observable that emits the items emitted by six Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6)
Returns an Observable that emits the items emitted by six Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6)
Returns an Observable that emits the items emitted by six Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6)
Returns an Observable that emits the items emitted by six Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6)
Returns an Observable that emits the items emitted by six Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7)
Returns an Observable that emits the items emitted by seven Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7)
Returns an Observable that emits the items emitted by seven Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7)
Returns an Observable that emits the items emitted by seven Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7)
Returns an Observable that emits the items emitted by seven Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7)
Returns an Observable that emits the items emitted by seven Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7)
Returns an Observable that emits the items emitted by seven Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7)
Returns an Observable that emits the items emitted by seven Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8)
Returns an Observable that emits the items emitted by eight Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8)
Returns an Observable that emits the items emitted by eight Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8)
Returns an Observable that emits the items emitted by eight Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8)
Returns an Observable that emits the items emitted by eight Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8)
Returns an Observable that emits the items emitted by eight Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8)
Returns an Observable that emits the items emitted by eight Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8)
Returns an Observable that emits the items emitted by eight Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8)
Returns an Observable that emits the items emitted by eight Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Returns an Observable that emits the items emitted by nine Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Returns an Observable that emits the items emitted by nine Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Returns an Observable that emits the items emitted by nine Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Returns an Observable that emits the items emitted by nine Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Returns an Observable that emits the items emitted by nine Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Returns an Observable that emits the items emitted by nine Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Returns an Observable that emits the items emitted by nine Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Returns an Observable that emits the items emitted by nine Observables, one after the other, without
interleaving them.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Returns an Observable that emits the items emitted by nine Observables, one after the other, without
interleaving them.
|
Observable<T> |
Observable.concatWith(Observable<? extends T> t1)
Returns an Observable that emits the items emitted from the current Observable, then the next, one after
the other, without interleaving them.
|
<T2,D1,D2,R> |
Observable.groupJoin(Observable<T2> right,
Func1<? super T,? extends Observable<D1>> leftDuration,
Func1<? super T2,? extends Observable<D2>> rightDuration,
Func2<? super T,? super Observable<T2>,? extends R> resultSelector)
Returns an Observable that correlates two Observables when they overlap in time and groups the results.
|
<TRight,TLeftDuration,TRightDuration,R> |
Observable.join(Observable<TRight> right,
Func1<T,Observable<TLeftDuration>> leftDurationSelector,
Func1<TRight,Observable<TRightDuration>> rightDurationSelector,
Func2<T,TRight,R> resultSelector)
Correlates the items emitted by two Observables based on overlapping durations.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends Observable<? extends T>> source)
Flattens an Observable that emits Observables into a single Observable that emits the items emitted by
those Observables, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends Observable<? extends T>> source,
int maxConcurrent)
Flattens an Observable that emits Observables into a single Observable that emits the items emitted by
those Observables, without any transformation, while limiting the maximum number of concurrent
subscriptions to these Observables.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T>[] sequences)
Flattens an Array of Observables into one Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T>[] sequences,
int maxConcurrent)
Flattens an Array of Observables into one Observable, without any transformation, while limiting the
number of concurrent subscriptions to these Observables.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2)
Flattens two Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2)
Flattens two Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3)
Flattens three Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3)
Flattens three Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3)
Flattens three Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4)
Flattens four Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4)
Flattens four Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4)
Flattens four Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4)
Flattens four Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5)
Flattens five Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5)
Flattens five Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5)
Flattens five Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5)
Flattens five Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5)
Flattens five Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6)
Flattens six Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6)
Flattens six Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6)
Flattens six Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6)
Flattens six Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6)
Flattens six Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6)
Flattens six Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7)
Flattens seven Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7)
Flattens seven Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7)
Flattens seven Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7)
Flattens seven Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7)
Flattens seven Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7)
Flattens seven Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7)
Flattens seven Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8)
Flattens eight Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8)
Flattens eight Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8)
Flattens eight Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8)
Flattens eight Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8)
Flattens eight Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8)
Flattens eight Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8)
Flattens eight Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8)
Flattens eight Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Flattens nine Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Flattens nine Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Flattens nine Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Flattens nine Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Flattens nine Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Flattens nine Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Flattens nine Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Flattens nine Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Flattens nine Observables into a single Observable, without any transformation.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends Observable<? extends T>> source)
Flattens an Observable that emits Observables into one Observable, in a way that allows an Observer to
receive all successfully emitted items from all of the source Observables without being interrupted by
an error notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends Observable<? extends T>> source,
int maxConcurrent)
Flattens an Observable that emits Observables into one Observable, in a way that allows an Observer to
receive all successfully emitted items from all of the source Observables without being interrupted by
an error notification from one of them, while limiting the
number of concurrent subscriptions to these Observables.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2)
Flattens two Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from each of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2)
Flattens two Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from each of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3)
Flattens three Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3)
Flattens three Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3)
Flattens three Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4)
Flattens four Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4)
Flattens four Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4)
Flattens four Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4)
Flattens four Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5)
Flattens five Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5)
Flattens five Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5)
Flattens five Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5)
Flattens five Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5)
Flattens five Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6)
Flattens six Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6)
Flattens six Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6)
Flattens six Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6)
Flattens six Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6)
Flattens six Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6)
Flattens six Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7)
Flattens seven Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7)
Flattens seven Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7)
Flattens seven Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7)
Flattens seven Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7)
Flattens seven Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7)
Flattens seven Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7)
Flattens seven Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8)
Flattens eight Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8)
Flattens eight Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8)
Flattens eight Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8)
Flattens eight Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8)
Flattens eight Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8)
Flattens eight Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8)
Flattens eight Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8)
Flattens eight Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Flattens nine Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Flattens nine Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Flattens nine Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Flattens nine Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Flattens nine Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Flattens nine Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Flattens nine Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Flattens nine Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends T> t1,
Observable<? extends T> t2,
Observable<? extends T> t3,
Observable<? extends T> t4,
Observable<? extends T> t5,
Observable<? extends T> t6,
Observable<? extends T> t7,
Observable<? extends T> t8,
Observable<? extends T> t9)
Flattens nine Observables into one Observable, in a way that allows an Observer to receive all
successfully emitted items from all of the source Observables without being interrupted by an error
notification from one of them.
|
Observable<T> |
Observable.mergeWith(Observable<? extends T> t1)
Flattens this and another Observable into a single Observable, without any transformation.
|
Observable<T> |
Observable.onErrorResumeNext(Observable<? extends T> resumeSequence)
Instructs an Observable to pass control to another Observable rather than invoking
onError if it encounters an error. |
Observable<T> |
Observable.onExceptionResumeNext(Observable<? extends T> resumeSequence)
|
<U> Observable<T> |
Observable.sample(Observable<U> sampler)
Returns an Observable that, when the specified
sampler Observable emits an item or completes,
emits the most recently emitted item (if any) emitted by the source Observable since the previous
emission from the sampler Observable. |
static <T> Observable<Boolean> |
Observable.sequenceEqual(Observable<? extends T> first,
Observable<? extends T> second)
Returns an Observable that emits a Boolean value that indicates whether two Observable sequences are the
same by comparing the items emitted by each Observable pairwise.
|
static <T> Observable<Boolean> |
Observable.sequenceEqual(Observable<? extends T> first,
Observable<? extends T> second)
Returns an Observable that emits a Boolean value that indicates whether two Observable sequences are the
same by comparing the items emitted by each Observable pairwise.
|
static <T> Observable<Boolean> |
Observable.sequenceEqual(Observable<? extends T> first,
Observable<? extends T> second,
Func2<? super T,? super T,Boolean> equality)
Returns an Observable that emits a Boolean value that indicates whether two Observable sequences are the
same by comparing the items emitted by each Observable pairwise based on the results of a specified
equality function.
|
static <T> Observable<Boolean> |
Observable.sequenceEqual(Observable<? extends T> first,
Observable<? extends T> second,
Func2<? super T,? super T,Boolean> equality)
Returns an Observable that emits a Boolean value that indicates whether two Observable sequences are the
same by comparing the items emitted by each Observable pairwise based on the results of a specified
equality function.
|
<U> Observable<T> |
Observable.skipUntil(Observable<U> other)
Returns an Observable that skips items emitted by the source Observable until a second Observable emits
an item.
|
Observable<T> |
Observable.startWith(Observable<T> values)
Returns an Observable that emits the items in a specified
Observable before it begins to emit
items emitted by the source Observable. |
Observable<T> |
Observable.switchIfEmpty(Observable<? extends T> alternate)
Returns an Observable that emits the items emitted by the source Observable or the items of an alternate
Observable if the source Observable is empty.
|
static <T> Observable<T> |
Observable.switchOnNext(Observable<? extends Observable<? extends T>> sequenceOfSequences)
Converts an Observable that emits Observables into an Observable that emits the items emitted by the
most recently emitted of those Observables.
|
<E> Observable<T> |
Observable.takeUntil(Observable<? extends E> other)
Returns an Observable that emits the items emitted by the source Observable until a second Observable
emits an item.
|
<U,V> Observable<T> |
Observable.timeout(Func0<? extends Observable<U>> firstTimeoutSelector,
Func1<? super T,? extends Observable<V>> timeoutSelector,
Observable<? extends T> other)
Returns an Observable that mirrors the source Observable, but switches to a fallback Observable if either
the first item emitted by the source Observable or any subsequent item doesn't arrive within time windows
defined by other Observables.
|
<V> Observable<T> |
Observable.timeout(Func1<? super T,? extends Observable<V>> timeoutSelector,
Observable<? extends T> other)
Returns an Observable that mirrors the source Observable, but that switches to a fallback Observable if
an item emitted by the source Observable doesn't arrive within a window of time after the emission of the
previous item, where that period of time is measured by an Observable that is a function of the previous
item.
|
Observable<T> |
Observable.timeout(long timeout,
TimeUnit timeUnit,
Observable<? extends T> other)
Returns an Observable that mirrors the source Observable but applies a timeout policy for each emitted
item.
|
Observable<T> |
Observable.timeout(long timeout,
TimeUnit timeUnit,
Observable<? extends T> other,
Scheduler scheduler)
Returns an Observable that mirrors the source Observable but applies a timeout policy for each emitted
item using a specified Scheduler.
|
<TOpening,TClosing> |
Observable.window(Observable<? extends TOpening> windowOpenings,
Func1<? super TOpening,? extends Observable<? extends TClosing>> closingSelector)
Returns an Observable that emits windows of items it collects from the source Observable.
|
<U> Observable<Observable<T>> |
Observable.window(Observable<U> boundary)
Returns an Observable that emits non-overlapping windows of items it collects from the source Observable
where the boundary of each window is determined by the items emitted from a specified boundary-governing
Observable.
|
<U,R> Observable<R> |
Observable.withLatestFrom(Observable<? extends U> other,
Func2<? super T,? super U,? extends R> resultSelector)
Merges the specified Observable into this Observable sequence by using the
resultSelector
function only when the source Observable (this instance) emits an item. |
static <R> Observable<R> |
Observable.zip(Observable<? extends Observable<?>> ws,
FuncN<? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
n items emitted, in sequence, by the n Observables emitted by a specified Observable.
|
static <T1,T2,R> Observable<R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Func2<? super T1,? super T2,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
two items emitted, in sequence, by two other Observables.
|
static <T1,T2,R> Observable<R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Func2<? super T1,? super T2,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
two items emitted, in sequence, by two other Observables.
|
static <T1,T2,T3,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Func3<? super T1,? super T2,? super T3,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
three items emitted, in sequence, by three other Observables.
|
static <T1,T2,T3,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Func3<? super T1,? super T2,? super T3,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
three items emitted, in sequence, by three other Observables.
|
static <T1,T2,T3,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Func3<? super T1,? super T2,? super T3,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
three items emitted, in sequence, by three other Observables.
|
static <T1,T2,T3,T4,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Func4<? super T1,? super T2,? super T3,? super T4,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
four items emitted, in sequence, by four other Observables.
|
static <T1,T2,T3,T4,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Func4<? super T1,? super T2,? super T3,? super T4,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
four items emitted, in sequence, by four other Observables.
|
static <T1,T2,T3,T4,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Func4<? super T1,? super T2,? super T3,? super T4,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
four items emitted, in sequence, by four other Observables.
|
static <T1,T2,T3,T4,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Func4<? super T1,? super T2,? super T3,? super T4,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
four items emitted, in sequence, by four other Observables.
|
static <T1,T2,T3,T4,T5,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Func5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
five items emitted, in sequence, by five other Observables.
|
static <T1,T2,T3,T4,T5,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Func5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
five items emitted, in sequence, by five other Observables.
|
static <T1,T2,T3,T4,T5,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Func5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
five items emitted, in sequence, by five other Observables.
|
static <T1,T2,T3,T4,T5,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Func5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
five items emitted, in sequence, by five other Observables.
|
static <T1,T2,T3,T4,T5,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Func5<? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
five items emitted, in sequence, by five other Observables.
|
static <T1,T2,T3,T4,T5,T6,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Func6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
six items emitted, in sequence, by six other Observables.
|
static <T1,T2,T3,T4,T5,T6,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Func6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
six items emitted, in sequence, by six other Observables.
|
static <T1,T2,T3,T4,T5,T6,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Func6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
six items emitted, in sequence, by six other Observables.
|
static <T1,T2,T3,T4,T5,T6,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Func6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
six items emitted, in sequence, by six other Observables.
|
static <T1,T2,T3,T4,T5,T6,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Func6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
six items emitted, in sequence, by six other Observables.
|
static <T1,T2,T3,T4,T5,T6,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Func6<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
six items emitted, in sequence, by six other Observables.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Func7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
seven items emitted, in sequence, by seven other Observables.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Func7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
seven items emitted, in sequence, by seven other Observables.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Func7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
seven items emitted, in sequence, by seven other Observables.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Func7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
seven items emitted, in sequence, by seven other Observables.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Func7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
seven items emitted, in sequence, by seven other Observables.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Func7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
seven items emitted, in sequence, by seven other Observables.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Func7<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
seven items emitted, in sequence, by seven other Observables.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Func8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
eight items emitted, in sequence, by eight other Observables.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Func8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
eight items emitted, in sequence, by eight other Observables.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Func8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
eight items emitted, in sequence, by eight other Observables.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Func8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
eight items emitted, in sequence, by eight other Observables.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Func8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
eight items emitted, in sequence, by eight other Observables.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Func8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
eight items emitted, in sequence, by eight other Observables.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Func8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
eight items emitted, in sequence, by eight other Observables.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Func8<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
eight items emitted, in sequence, by eight other Observables.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Observable<? extends T9> o9,
Func9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
nine items emitted, in sequence, by nine other Observables.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Observable<? extends T9> o9,
Func9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
nine items emitted, in sequence, by nine other Observables.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Observable<? extends T9> o9,
Func9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
nine items emitted, in sequence, by nine other Observables.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Observable<? extends T9> o9,
Func9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
nine items emitted, in sequence, by nine other Observables.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Observable<? extends T9> o9,
Func9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
nine items emitted, in sequence, by nine other Observables.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Observable<? extends T9> o9,
Func9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
nine items emitted, in sequence, by nine other Observables.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Observable<? extends T9> o9,
Func9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
nine items emitted, in sequence, by nine other Observables.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Observable<? extends T9> o9,
Func9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
nine items emitted, in sequence, by nine other Observables.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Observable<? extends T4> o4,
Observable<? extends T5> o5,
Observable<? extends T6> o6,
Observable<? extends T7> o7,
Observable<? extends T8> o8,
Observable<? extends T9> o9,
Func9<? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? super T9,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
nine items emitted, in sequence, by nine other Observables.
|
<T2,R> Observable<R> |
Observable.zipWith(Observable<? extends T2> other,
Func2<? super T,? super T2,? extends R> zipFunction)
Returns an Observable that emits items that are the result of applying a specified function to pairs of
values, one each from the source Observable and another specified Observable.
|
Modifier and Type | Method and Description |
---|---|
static <T> Observable<T> |
Observable.amb(Iterable<? extends Observable<? extends T>> sources)
Mirrors the one Observable in an Iterable of several Observables that first either emits an item or sends
a termination notification.
|
<TClosing> Observable<List<T>> |
Observable.buffer(Func0<? extends Observable<? extends TClosing>> bufferClosingSelector)
Returns an Observable that emits buffers of items it collects from the source Observable.
|
<TOpening,TClosing> |
Observable.buffer(Observable<? extends TOpening> bufferOpenings,
Func1<? super TOpening,? extends Observable<? extends TClosing>> bufferClosingSelector)
Returns an Observable that emits buffers of items it collects from the source Observable.
|
static <T,R> Observable<R> |
Observable.combineLatest(List<? extends Observable<? extends T>> sources,
FuncN<? extends R> combineFunction)
Combines a list of source Observables by emitting an item that aggregates the latest values of each of
the source Observables each time an item is received from any of the source Observables, where this
aggregation is defined by a specified function.
|
static <T> Observable<T> |
Observable.concat(Observable<? extends Observable<? extends T>> observables)
Returns an Observable that emits the items emitted by each of the Observables emitted by the source
Observable, one after the other, without interleaving them.
|
<R> Observable<R> |
Observable.concatMap(Func1<? super T,? extends Observable<? extends R>> func)
Returns a new Observable that emits items resulting from applying a function that you supply to each item
emitted by the source Observable, where that function returns an Observable, and then emitting the items
that result from concatinating those resulting Observables.
|
<U> Observable<T> |
Observable.debounce(Func1<? super T,? extends Observable<U>> debounceSelector)
Returns an Observable that mirrors the source Observable, except that it drops items emitted by the
source Observable that are followed by another item within a computed debounce duration.
|
static <T> Observable<T> |
Observable.defer(Func0<Observable<T>> observableFactory)
Returns an Observable that calls an Observable factory to create an Observable for each new Observer
that subscribes.
|
<U,V> Observable<T> |
Observable.delay(Func0<? extends Observable<U>> subscriptionDelay,
Func1<? super T,? extends Observable<V>> itemDelay)
Returns an Observable that delays the subscription to and emissions from the souce Observable via another
Observable on a per-item basis.
|
<U,V> Observable<T> |
Observable.delay(Func0<? extends Observable<U>> subscriptionDelay,
Func1<? super T,? extends Observable<V>> itemDelay)
Returns an Observable that delays the subscription to and emissions from the souce Observable via another
Observable on a per-item basis.
|
<U> Observable<T> |
Observable.delay(Func1<? super T,? extends Observable<U>> itemDelay)
Returns an Observable that delays the emissions of the source Observable via another Observable on a
per-item basis.
|
<U> Observable<T> |
Observable.delaySubscription(Func0<? extends Observable<U>> subscriptionDelay)
Returns an Observable that delays the subscription to the source Observable until a second Observable
emits an item.
|
<R> Observable<R> |
Observable.flatMap(Func1<? super T,? extends Observable<? extends R>> func)
Returns an Observable that emits items based on applying a function that you supply to each item emitted
by the source Observable, where that function returns an Observable, and then merging those resulting
Observables and emitting the results of this merger.
|
<R> Observable<R> |
Observable.flatMap(Func1<? super T,? extends Observable<? extends R>> onNext,
Func1<? super Throwable,? extends Observable<? extends R>> onError,
Func0<? extends Observable<? extends R>> onCompleted)
Returns an Observable that applies a function to each item emitted or notification raised by the source
Observable and then flattens the Observables returned from these functions and emits the resulting items.
|
<R> Observable<R> |
Observable.flatMap(Func1<? super T,? extends Observable<? extends R>> onNext,
Func1<? super Throwable,? extends Observable<? extends R>> onError,
Func0<? extends Observable<? extends R>> onCompleted)
Returns an Observable that applies a function to each item emitted or notification raised by the source
Observable and then flattens the Observables returned from these functions and emits the resulting items.
|
<R> Observable<R> |
Observable.flatMap(Func1<? super T,? extends Observable<? extends R>> onNext,
Func1<? super Throwable,? extends Observable<? extends R>> onError,
Func0<? extends Observable<? extends R>> onCompleted)
Returns an Observable that applies a function to each item emitted or notification raised by the source
Observable and then flattens the Observables returned from these functions and emits the resulting items.
|
<R> Observable<R> |
Observable.flatMap(Func1<? super T,? extends Observable<? extends R>> onNext,
Func1<? super Throwable,? extends Observable<? extends R>> onError,
Func0<? extends Observable<? extends R>> onCompleted,
int maxConcurrent)
Returns an Observable that applies a function to each item emitted or notification raised by the source
Observable and then flattens the Observables returned from these functions and emits the resulting items,
while limiting the maximum number of concurrent subscriptions to these Observables.
|
<R> Observable<R> |
Observable.flatMap(Func1<? super T,? extends Observable<? extends R>> onNext,
Func1<? super Throwable,? extends Observable<? extends R>> onError,
Func0<? extends Observable<? extends R>> onCompleted,
int maxConcurrent)
Returns an Observable that applies a function to each item emitted or notification raised by the source
Observable and then flattens the Observables returned from these functions and emits the resulting items,
while limiting the maximum number of concurrent subscriptions to these Observables.
|
<R> Observable<R> |
Observable.flatMap(Func1<? super T,? extends Observable<? extends R>> onNext,
Func1<? super Throwable,? extends Observable<? extends R>> onError,
Func0<? extends Observable<? extends R>> onCompleted,
int maxConcurrent)
Returns an Observable that applies a function to each item emitted or notification raised by the source
Observable and then flattens the Observables returned from these functions and emits the resulting items,
while limiting the maximum number of concurrent subscriptions to these Observables.
|
<R> Observable<R> |
Observable.flatMap(Func1<? super T,? extends Observable<? extends R>> func,
int maxConcurrent)
Returns an Observable that emits items based on applying a function that you supply to each item emitted
by the source Observable, where that function returns an Observable, and then merging those resulting
Observables and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these Observables.
|
<U,R> Observable<R> |
Observable.flatMap(Func1<? super T,? extends Observable<? extends U>> collectionSelector,
Func2<? 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 Observable and a specified collection Observable.
|
<U,R> Observable<R> |
Observable.flatMap(Func1<? super T,? extends Observable<? extends U>> collectionSelector,
Func2<? super T,? super U,? extends R> resultSelector,
int maxConcurrent)
Returns an Observable that emits the results of a specified function to the pair of values emitted by the
source Observable and a specified collection Observable, while limiting the maximum number of concurrent
subscriptions to these Observables.
|
<R> Observable<R> |
Single.flatMapObservable(Func1<? super T,? extends Observable<? extends R>> func)
Returns an Observable that emits items based on applying a specified function to the item emitted by the
source Observable, where that function returns an Observable.
|
<T2,D1,D2,R> |
Observable.groupJoin(Observable<T2> right,
Func1<? super T,? extends Observable<D1>> leftDuration,
Func1<? super T2,? extends Observable<D2>> rightDuration,
Func2<? super T,? super Observable<T2>,? extends R> resultSelector)
Returns an Observable that correlates two Observables when they overlap in time and groups the results.
|
<T2,D1,D2,R> |
Observable.groupJoin(Observable<T2> right,
Func1<? super T,? extends Observable<D1>> leftDuration,
Func1<? super T2,? extends Observable<D2>> rightDuration,
Func2<? super T,? super Observable<T2>,? extends R> resultSelector)
Returns an Observable that correlates two Observables when they overlap in time and groups the results.
|
<T2,D1,D2,R> |
Observable.groupJoin(Observable<T2> right,
Func1<? super T,? extends Observable<D1>> leftDuration,
Func1<? super T2,? extends Observable<D2>> rightDuration,
Func2<? super T,? super Observable<T2>,? extends R> resultSelector)
Returns an Observable that correlates two Observables when they overlap in time and groups the results.
|
<TRight,TLeftDuration,TRightDuration,R> |
Observable.join(Observable<TRight> right,
Func1<T,Observable<TLeftDuration>> leftDurationSelector,
Func1<TRight,Observable<TRightDuration>> rightDurationSelector,
Func2<T,TRight,R> resultSelector)
Correlates the items emitted by two Observables based on overlapping durations.
|
<TRight,TLeftDuration,TRightDuration,R> |
Observable.join(Observable<TRight> right,
Func1<T,Observable<TLeftDuration>> leftDurationSelector,
Func1<TRight,Observable<TRightDuration>> rightDurationSelector,
Func2<T,TRight,R> resultSelector)
Correlates the items emitted by two Observables based on overlapping durations.
|
static <T> Observable<T> |
Observable.merge(Iterable<? extends Observable<? extends T>> sequences)
Flattens an Iterable of Observables into one Observable, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Iterable<? extends Observable<? extends T>> sequences,
int maxConcurrent)
Flattens an Iterable of Observables into one Observable, without any transformation, while limiting the
number of concurrent subscriptions to these Observables.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends Observable<? extends T>> source)
Flattens an Observable that emits Observables into a single Observable that emits the items emitted by
those Observables, without any transformation.
|
static <T> Observable<T> |
Observable.merge(Observable<? extends Observable<? extends T>> source,
int maxConcurrent)
Flattens an Observable that emits Observables into a single Observable that emits the items emitted by
those Observables, without any transformation, while limiting the maximum number of concurrent
subscriptions to these Observables.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends Observable<? extends T>> source)
Flattens an Observable that emits Observables into one Observable, in a way that allows an Observer to
receive all successfully emitted items from all of the source Observables without being interrupted by
an error notification from one of them.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends Observable<? extends T>> source,
int maxConcurrent)
Flattens an Observable that emits Observables into one Observable, in a way that allows an Observer to
receive all successfully emitted items from all of the source Observables without being interrupted by
an error notification from one of them, while limiting the
number of concurrent subscriptions to these Observables.
|
Observable<T> |
Observable.onErrorResumeNext(Func1<Throwable,? extends Observable<? extends T>> resumeFunction)
Instructs an Observable to pass control to another Observable rather than invoking
onError if it encounters an error. |
<R> Observable<R> |
Observable.publish(Func1<? super Observable<T>,? extends Observable<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. |
<R> Observable<R> |
Observable.publish(Func1<? super Observable<T>,? extends Observable<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(Func1<? super Observable<? extends Void>,? extends Observable<?>> notificationHandler)
Returns an Observable that emits the same values as the source Observable with the exception of an
onCompleted . |
Observable<T> |
Observable.repeatWhen(Func1<? super Observable<? extends Void>,? extends Observable<?>> notificationHandler)
Returns an Observable that emits the same values as the source Observable with the exception of an
onCompleted . |
Observable<T> |
Observable.repeatWhen(Func1<? super Observable<? extends Void>,? extends Observable<?>> notificationHandler,
Scheduler scheduler)
Returns an Observable that emits the same values as the source Observable with the exception of an
onCompleted . |
Observable<T> |
Observable.repeatWhen(Func1<? super Observable<? extends Void>,? extends Observable<?>> notificationHandler,
Scheduler scheduler)
Returns an Observable that emits the same values as the source Observable with the exception of an
onCompleted . |
<R> Observable<R> |
Observable.replay(Func1<? super Observable<T>,? extends Observable<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 Observable. |
<R> Observable<R> |
Observable.replay(Func1<? super Observable<T>,? extends Observable<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 Observable. |
<R> Observable<R> |
Observable.replay(Func1<? super Observable<T>,? extends Observable<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 Observable,
replaying bufferSize notifications. |
<R> Observable<R> |
Observable.replay(Func1<? super Observable<T>,? extends Observable<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 Observable,
replaying bufferSize notifications. |
<R> Observable<R> |
Observable.replay(Func1<? super Observable<T>,? extends Observable<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 Observable,
replaying no more than bufferSize items that were emitted within a specified time window. |
<R> Observable<R> |
Observable.replay(Func1<? super Observable<T>,? extends Observable<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 Observable,
replaying no more than bufferSize items that were emitted within a specified time window. |
<R> Observable<R> |
Observable.replay(Func1<? super Observable<T>,? extends Observable<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 Observable,
replaying no more than bufferSize items that were emitted within a specified time window. |
<R> Observable<R> |
Observable.replay(Func1<? super Observable<T>,? extends Observable<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 Observable,
replaying no more than bufferSize items that were emitted within a specified time window. |
<R> Observable<R> |
Observable.replay(Func1<? super Observable<T>,? extends Observable<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 Observable,
replaying a maximum of bufferSize items. |
<R> Observable<R> |
Observable.replay(Func1<? super Observable<T>,? extends Observable<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 Observable,
replaying a maximum of bufferSize items. |
<R> Observable<R> |
Observable.replay(Func1<? super Observable<T>,? extends Observable<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 Observable,
replaying all items that were emitted within a specified time window. |
<R> Observable<R> |
Observable.replay(Func1<? super Observable<T>,? extends Observable<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 Observable,
replaying all items that were emitted within a specified time window. |
<R> Observable<R> |
Observable.replay(Func1<? super Observable<T>,? extends Observable<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 Observable,
replaying all items that were emitted within a specified time window. |
<R> Observable<R> |
Observable.replay(Func1<? super Observable<T>,? extends Observable<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 Observable,
replaying all items that were emitted within a specified time window. |
<R> Observable<R> |
Observable.replay(Func1<? super Observable<T>,? extends Observable<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 Observable. |
<R> Observable<R> |
Observable.replay(Func1<? super Observable<T>,? extends Observable<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 Observable. |
Observable<T> |
Observable.retryWhen(Func1<? super Observable<? extends Throwable>,? extends Observable<?>> notificationHandler)
Returns an Observable that emits the same values as the source observable with the exception of an
onError . |
Observable<T> |
Observable.retryWhen(Func1<? super Observable<? extends Throwable>,? extends Observable<?>> notificationHandler)
Returns an Observable that emits the same values as the source observable with the exception of an
onError . |
Observable<T> |
Observable.retryWhen(Func1<? super Observable<? extends Throwable>,? extends Observable<?>> notificationHandler,
Scheduler scheduler)
Returns an Observable that emits the same values as the source observable with the exception of an
onError . |
Observable<T> |
Observable.retryWhen(Func1<? super Observable<? extends Throwable>,? extends Observable<?>> notificationHandler,
Scheduler scheduler)
Returns an Observable that emits the same values as the source observable with the exception of an
onError . |
<R> Observable<R> |
Observable.switchMap(Func1<? super T,? extends Observable<? extends R>> func)
Returns a new Observable by applying a function that you supply to each item emitted by the source
Observable that returns an Observable, and then emitting the items emitted by the most recently emitted
of these Observables.
|
static <T> Observable<T> |
Observable.switchOnNext(Observable<? extends Observable<? extends T>> sequenceOfSequences)
Converts an Observable that emits Observables into an Observable that emits the items emitted by the
most recently emitted of those Observables.
|
<U,V> Observable<T> |
Observable.timeout(Func0<? extends Observable<U>> firstTimeoutSelector,
Func1<? super T,? extends Observable<V>> timeoutSelector)
Returns an Observable that mirrors the source Observable, but notifies observers of a
TimeoutException if either the first item emitted by the source Observable or any subsequent item
doesn't arrive within time windows defined by other Observables. |
<U,V> Observable<T> |
Observable.timeout(Func0<? extends Observable<U>> firstTimeoutSelector,
Func1<? super T,? extends Observable<V>> timeoutSelector)
Returns an Observable that mirrors the source Observable, but notifies observers of a
TimeoutException if either the first item emitted by the source Observable or any subsequent item
doesn't arrive within time windows defined by other Observables. |
<U,V> Observable<T> |
Observable.timeout(Func0<? extends Observable<U>> firstTimeoutSelector,
Func1<? super T,? extends Observable<V>> timeoutSelector,
Observable<? extends T> other)
Returns an Observable that mirrors the source Observable, but switches to a fallback Observable if either
the first item emitted by the source Observable or any subsequent item doesn't arrive within time windows
defined by other Observables.
|
<U,V> Observable<T> |
Observable.timeout(Func0<? extends Observable<U>> firstTimeoutSelector,
Func1<? super T,? extends Observable<V>> timeoutSelector,
Observable<? extends T> other)
Returns an Observable that mirrors the source Observable, but switches to a fallback Observable if either
the first item emitted by the source Observable or any subsequent item doesn't arrive within time windows
defined by other Observables.
|
<V> Observable<T> |
Observable.timeout(Func1<? super T,? extends Observable<V>> timeoutSelector)
Returns an Observable that mirrors the source Observable, but notifies observers of a
TimeoutException if an item emitted by the source Observable doesn't arrive within a window of
time after the emission of the previous item, where that period of time is measured by an Observable that
is a function of the previous item. |
<V> Observable<T> |
Observable.timeout(Func1<? super T,? extends Observable<V>> timeoutSelector,
Observable<? extends T> other)
Returns an Observable that mirrors the source Observable, but that switches to a fallback Observable if
an item emitted by the source Observable doesn't arrive within a window of time after the emission of the
previous item, where that period of time is measured by an Observable that is a function of the previous
item.
|
static <T,Resource> |
Observable.using(Func0<Resource> resourceFactory,
Func1<? super Resource,? extends Observable<? extends T>> observableFactory,
Action1<? super Resource> disposeAction)
Constructs an Observable that creates a dependent resource object which is disposed of on unsubscription.
|
static <T,Resource> |
Observable.using(Func0<Resource> resourceFactory,
Func1<? super Resource,? extends Observable<? extends T>> observableFactory,
Action1<? super Resource> disposeAction,
boolean disposeEagerly)
Constructs an Observable that creates a dependent resource object which is disposed of just before
termination if you have set
disposeEagerly to true and unsubscription does not occur
before termination. |
<TClosing> Observable<Observable<T>> |
Observable.window(Func0<? extends Observable<? extends TClosing>> closingSelector)
Returns an Observable that emits windows of items it collects from the source Observable.
|
<TOpening,TClosing> |
Observable.window(Observable<? extends TOpening> windowOpenings,
Func1<? super TOpening,? extends Observable<? extends TClosing>> closingSelector)
Returns an Observable that emits windows of items it collects from the source Observable.
|
static <R> Observable<R> |
Observable.zip(Iterable<? extends Observable<?>> ws,
FuncN<? extends R> zipFunction)
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 Observables.
|
static <R> Observable<R> |
Observable.zip(Observable<? extends Observable<?>> ws,
FuncN<? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
n items emitted, in sequence, by the n Observables emitted by a specified Observable.
|
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() 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 | Method and Description |
---|---|
Observable<T> |
ConnectableObservable.autoConnect()
Returns an Observable that automatically connects to this ConnectableObservable
when the first Subscriber subscribes.
|
Observable<T> |
ConnectableObservable.autoConnect(int numberOfSubscribers)
Returns an Observable that automatically connects to this ConnectableObservable
when the specified number of Subscribers subscribe to it.
|
Observable<T> |
ConnectableObservable.autoConnect(int numberOfSubscribers,
Action1<? super Subscription> connection)
Returns an Observable that automatically connects to this ConnectableObservable
when the specified number of Subscribers subscribe to it and calls the
specified callback with the Subscription associated with the established connection.
|
Observable<T> |
ConnectableObservable.refCount()
Returns an
Observable that stays connected to this ConnectableObservable as long as there
is at least one subscription to this ConnectableObservable . |
Observable<T> |
AbstractOnSubscribe.toObservable()
Convenience method to create an Observable from this implemented instance.
|
Modifier and Type | Method and Description |
---|---|
static <K,T> GroupedObservable<K,T> |
GroupedObservable.from(K key,
Observable<T> o)
Converts an
Observable into a GroupedObservable with a particular key. |
static <T> BlockingObservable<T> |
BlockingObservable.from(Observable<? extends T> o)
Converts an
Observable into a BlockingObservable . |
Modifier and Type | Method and Description |
---|---|
<T> Observable.OnSubscribe<T> |
RxJavaObservableExecutionHook.onSubscribeStart(Observable<? extends T> observableInstance,
Observable.OnSubscribe<T> onSubscribe)
Invoked before
subscribe(rx.Subscriber) is about to be executed. |
Modifier and Type | Class and Description |
---|---|
class |
AsyncSubject<T>
Subject that publishes only the last item observed to each
Observer that has subscribed, when the
source Observable completes. |
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>
Subject that, once an
Observer has subscribed, emits all subsequently observed items to the
subscriber. |
class |
ReplaySubject<T>
Subject that buffers all items it observes and replays them to any
Observer that subscribes. |
class |
SerializedSubject<T,R>
Wraps a
Subject so that it is safe to call its various on methods from different threads. |
class |
Subject<T,R>
Represents an object that is both an Observable and an Observer.
|
class |
TestSubject<T>
A variety of Subject that is useful for testing purposes.
|
Copyright © 2015. All Rights Reserved.