Uses of Class
rx.Observable
Packages that use Observable
Package
Description
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
Classes extending the Observable base reactive class, synchronous and
asynchronous event generators.
Callback types and a central plugin handler class to hook into the lifecycle
of the base reactive types and schedulers.
Classes extending the Observable base reactive class and implementing
the Observer interface at the same time (aka hot Observables).
-
Uses of Observable in rx
Fields in rx declared as ObservableModifier and TypeFieldDescription(package private) final Observable
<T> Observable.OnSubscribeExtend.parent
Methods in rx that return ObservableModifier and TypeMethodDescriptionfinal Observable
<Boolean> 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.final 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.final <T> Observable
<T> Completable.andThen
(Observable<T> next) Returns an Observable which will subscribe to this Completable and once that is completed then will subscribe to thenext
Observable.final Observable
<T> Observable.asObservable()
Portrays a object of an Observable subclass as a simple Observable object.private static <T> Observable
<T> Single.asObservable
(Single<T> t) final Observable
<List<T>> Observable.buffer
(int count) Returns an Observable that emits buffers of items it collects from the source Observable.final Observable
<List<T>> Observable.buffer
(int count, int skip) Returns an Observable that emits buffers of items it collects from the source Observable.final Observable
<List<T>> Returns an Observable that emits buffers of items it collects from the source Observable.final Observable
<List<T>> Returns an Observable that emits buffers of items it collects from the source Observable.final Observable
<List<T>> Returns an Observable that emits buffers of items it collects from the source Observable.final Observable
<List<T>> Returns an Observable that emits buffers of items it collects from the source Observable.final Observable
<List<T>> Returns an Observable that emits buffers of items it collects from the source Observable.final Observable
<List<T>> Returns an Observable that emits buffers of items it collects from the source Observable.final <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.final <TOpening,
TClosing>
Observable<List<T>> 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.final <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.final <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.final Observable
<T> Observable.cache()
Returns an Observable that subscribes to this Observable lazily, caches all of its events and replays them, in the same order as received, to all the downstream subscribers.final Observable
<T> Observable.cache
(int initialCapacity) Deprecated.final Observable
<T> Observable.cacheWithInitialCapacity
(int initialCapacity) Returns an Observable that subscribes to this Observable lazily, caches all of its events and replays them, in the same order as received, to all the downstream subscribers.final <R> Observable
<R> Returns an Observable that emits the items emitted by the source Observable, converted to the specified type.final <R> Observable
<R> 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
(Iterable<? extends Observable<? extends T>> sources, FuncN<? extends R> combineFunction) Combines a collection 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,
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<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<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<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<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<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<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<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,
R> Observable <R> Observable.combineLatestDelayError
(Iterable<? extends Observable<? extends T>> sources, FuncN<? extends R> combineFunction) Combines a collection 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 and delays any error from the sources until all source Observables terminate.<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> Returns an Observable that emits the items emitted by two Singles, one after the other.static <T> Observable
<T> 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.static <T> Observable
<T> Observable.concatDelayError
(Iterable<? extends Observable<? extends T>> sources) Concatenates the Iterable sequence of Observables into a single sequence by subscribing to each Observable, one after the other, one at a time and delays any errors till the all inner Observables terminate.static <T> Observable
<T> Observable.concatDelayError
(Observable<? extends Observable<? extends T>> sources) Concatenates the Observable sequence of Observables into a single sequence by subscribing to each inner Observable, one after the other, one at a time and delays any errors till the all inner and the outer Observables terminate.static <T> Observable
<T> Observable.concatEager
(Iterable<? extends Observable<? extends T>> sources) Concatenates a sequence of Observables eagerly into a single stream of values.static <T> Observable
<T> Observable.concatEager
(Iterable<? extends Observable<? extends T>> sources, int capacityHint) Concatenates a sequence of Observables eagerly into a single stream of values.static <T> Observable
<T> Observable.concatEager
(Observable<? extends Observable<? extends T>> sources) Concatenates an Observable sequence of Observables eagerly into a single stream of values.static <T> Observable
<T> Observable.concatEager
(Observable<? extends Observable<? extends T>> sources, int capacityHint) Concatenates an Observable sequence of Observables eagerly into a single stream of values.static <T> Observable
<T> Observable.concatEager
(Observable<? extends T> o1, Observable<? extends T> o2) Concatenates two source Observables eagerly into a single stream of values.static <T> Observable
<T> Observable.concatEager
(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3) Concatenates three sources eagerly into a single stream of values.static <T> Observable
<T> Observable.concatEager
(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4) Concatenates four sources eagerly into a single stream of values.static <T> Observable
<T> Observable.concatEager
(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5) Concatenates five sources eagerly into a single stream of values.static <T> Observable
<T> Observable.concatEager
(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5, Observable<? extends T> o6) Concatenates six sources eagerly into a single stream of values.static <T> Observable
<T> Observable.concatEager
(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) Concatenates seven sources eagerly into a single stream of values.static <T> Observable
<T> Observable.concatEager
(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) Concatenates eight sources eagerly into a single stream of values.static <T> Observable
<T> Observable.concatEager
(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) Concatenates nine sources eagerly into a single stream of values.final <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 concatenating those resulting Observables.final <R> Observable
<R> Observable.concatMapDelayError
(Func1<? super T, ? extends Observable<? extends R>> func) Maps each of the items into an Observable, subscribes to them one after the other, one at a time and emits their values in order while delaying any error from either this or any of the inner Observables till all of them terminate.final <R> Observable
<R> Observable.concatMapEager
(Func1<? super T, ? extends Observable<? extends R>> mapper) Maps a sequence of values into Observables and concatenates these Observables eagerly into a single Observable.final <R> Observable
<R> Observable.concatMapEager
(Func1<? super T, ? extends Observable<? extends R>> mapper, int capacityHint) Maps a sequence of values into Observables and concatenates these Observables eagerly into a single Observable.final <R> Observable
<R> Observable.concatMapEager
(Func1<? super T, ? extends Observable<? extends R>> mapper, int capacityHint, int maxConcurrent) Maps a sequence of values into Observables and concatenates these Observables eagerly into a single Observable.final <R> Observable
<R> Observable.concatMapIterable
(Func1<? super T, ? extends Iterable<? extends R>> collectionSelector) Returns an Observable that concatenate each item emitted by the source Observable with the values in an Iterable corresponding to that item that is generated by a selector.final 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.final 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.final Observable
<Boolean> Returns an Observable that emits a Boolean that indicates whether the source Observable emitted a specified item.final Observable
<Integer> Observable.count()
Returns an Observable that emits the count of the total number of items emitted by the source Observable.final 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) This method requires advanced knowledge about building operators and data sources; please consider other standard methods first; Returns an Observable that will execute the specified function when aSubscriber
subscribes to it.static <S,
T> Observable <T> Observable.create
(AsyncOnSubscribe<S, T> asyncOnSubscribe) Returns an Observable that respects the back-pressure semantics.static <S,
T> Observable <T> Observable.create
(SyncOnSubscribe<S, T> syncOnSubscribe) Returns an Observable that respects the back-pressure semantics.final Observable
<T> 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.final Observable
<T> 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.final <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.final 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.final Observable
<T> Returns an Observable that emits the items emitted by the source Observable shifted forward in time by a specified delay.final Observable
<T> Returns an Observable that emits the items emitted by the source Observable shifted forward in time by a specified delay.final <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 source Observable via another Observable on a per-item basis.final <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.final 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.final 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.final <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.final <U> Observable
<T> Observable.delaySubscription
(Observable<U> other) Returns an Observable that delays the subscription to this Observable until the other Observable emits an element or completes normally.final <T2> Observable
<T2> Observable.dematerialize()
Returns an Observable that reverses the effect ofmaterialize
by transforming theNotification
objects emitted by the source Observable into the items or notifications they represent.final Observable
<T> Observable.distinct()
Returns an Observable that emits all items emitted by the source Observable that are distinct.final <U> Observable
<T> Returns an Observable that emits all items emitted by the source Observable that are distinct according to a key selector function.final Observable
<T> Observable.distinctUntilChanged()
Returns an Observable that emits all items emitted by the source Observable that are distinct from their immediate predecessors.final <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.final Observable
<T> Observable.distinctUntilChanged
(Func2<? super T, ? super T, Boolean> comparator) Returns an Observable that emits all items emitted by the source Observable that are distinct from their immediate predecessors when compared with each other via the provided comparator function.final Observable
<T> Observable.doAfterTerminate
(Action0 action) final Observable
<T> Observable.doOnCompleted
(Action0 onCompleted) Modifies the source Observable so that it invokes an action when it callsonCompleted
.final Observable
<T> Observable.doOnEach
(Action1<Notification<? super T>> onNotification) Modifies the source Observable so that it invokes an action for each item it emits.final Observable
<T> Modifies the source Observable so that it notifies an Observer for each item and terminal event it emits.final Observable
<T> Modifies the source Observable so that it invokes an action if it callsonError
.final Observable
<T> Modifies the source Observable so that it invokes an action when it callsonNext
.final Observable
<T> Observable.doOnRequest
(Action1<Long> onRequest) Modifies the sourceObservable
so that it invokes the given action when it receives a request for more items.final Observable
<T> Observable.doOnSubscribe
(Action0 subscribe) Modifies the sourceObservable
so that it invokes the given action when it is subscribed from its subscribers.final Observable
<T> Observable.doOnTerminate
(Action0 onTerminate) Modifies the source Observable so that it invokes an action when it callsonCompleted
oronError
.final Observable
<T> Observable.doOnUnsubscribe
(Action0 unsubscribe) Calls the unsubscribeAction0
if the downstream unsubscribes the sequence.final 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 Observable.final 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 theObserver
and immediately invokes itsonCompleted
method.final <T> Observable
<T> Completable.endWith
(Observable<T> next) Deprecated.UseCompletable.andThen(rx.Observable)
instead.static <T> Observable
<T> final Observable
<Boolean> Returns an Observable that emitstrue
if any item emitted by the source Observable satisfies a specified condition, otherwisefalse
.final Observable
<T> Filters items emitted by an Observable by only emitting those that satisfy a specified predicate.final Observable
<T> Deprecated.usedoAfterTerminate(Action0)
instead.final Observable
<T> Observable.first()
Returns an Observable that emits only the very first item emitted by the source Observable, or notifies of anNoSuchElementException
if the source Observable is empty.final Observable
<T> Returns an Observable that emits only the very first item emitted by the source Observable that satisfies a specified condition, or notifies of anNoSuchElementException
if no such items are emitted.final 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.final 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.final <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.final <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.final <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.final <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.final <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.final <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.final <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.final <R> Observable
<R> Observable.flatMapIterable
(Func1<? super T, ? extends Iterable<? extends R>> collectionSelector, int maxConcurrent) 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, while limiting the number of concurrent subscriptions to these Observables.final <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.final <U,
R> Observable <R> Observable.flatMapIterable
(Func1<? super T, ? extends Iterable<? extends U>> collectionSelector, Func2<? super T, ? super U, ? extends R> resultSelector, int maxConcurrent) 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, while limiting the number of concurrent subscriptions to these Observables.final <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> Converts anIterable
sequence into an Observable that emits the items in the sequence.static <T> Observable
<T> Converts aFuture
into an Observable.static <T> Observable
<T> Converts aFuture
into an Observable, with a timeout on the Future.static <T> Observable
<T> static <T> Observable
<T> Observable.from
(T[] array) Converts an Array into an Observable that emits the items in the Array.static <T> Observable
<T> Observable.fromAsync
(Action1<AsyncEmitter<T>> asyncEmitter, AsyncEmitter.BackpressureMode backpressure) Provides an API (via a cold Observable) that bridges the reactive world with the callback-style, generally non-backpressured world.static <T> Observable
<T> Observable.fromCallable
(Callable<? extends T> func) Returns an Observable that, when an observer subscribes to it, invokes a function you specify and then emits the value returned from that function.final <K> Observable
<GroupedObservable<K, T>> Groups the items emitted by anObservable
according to a specified criterion, and emits these grouped items asGroupedObservable
s.final <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 anObservable
according to a specified criterion, and emits these grouped items asGroupedObservable
s.final <K,
R> Observable <GroupedObservable<K, R>> Observable.groupBy
(Func1<? super T, ? extends K> keySelector, Func1<? super T, ? extends R> elementSelector, Func1<Action1<K>, Map<K, Object>> evictingMapFactory) Groups the items emitted by anObservable
according to a specified criterion, and emits these grouped items asGroupedObservable
s.final <T2,
D1, D2, R>
Observable<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.final Observable
<T> Observable.ignoreElements()
Ignores all items emitted by the source Observable and only callsonCompleted
oronError
.static Observable
<Long> Returns an Observable that emits a0L
after theinitialDelay
and ever increasing numbers after eachperiod
of time thereafter.static Observable
<Long> Returns an Observable that emits a0L
after theinitialDelay
and ever increasing numbers after eachperiod
of time thereafter, on a specifiedScheduler
.static Observable
<Long> Returns an Observable that emits a sequential number every specified interval of time.static Observable
<Long> Returns an Observable that emits a sequential number every specified interval of time, on a specified Scheduler.final Observable
<Boolean> Observable.isEmpty()
Returns an Observable that emitstrue
if the source Observable is empty, otherwisefalse
.final <TRight,
TLeftDuration, TRightDuration, R>
Observable<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.final Observable
<T> Observable.last()
Returns an Observable that emits the last item emitted by the source Observable or notifies observers of aNoSuchElementException
if the source Observable is empty.final Observable
<T> Returns an Observable that emits only the last item emitted by the source Observable that satisfies a given condition, or notifies of aNoSuchElementException
if no such items are emitted.final 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.final 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.final <R> Observable
<R> Observable.lift
(Observable.Operator<? extends R, ? super T> operator) This method requires advanced knowledge about building operators; please consider other standard composition methods first; 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.final Observable
<T> Observable.limit
(int count) Returns an Observable that emits only the firstcount
items emitted by the source Observable.final <R> Observable
<R> Returns an Observable that applies a specified function to each item emitted by the source Observable and emits the results of these function applications.private <R> Observable
<R> Observable.mapNotification
(Func1<? super T, ? extends R> onNext, Func1<? super Throwable, ? extends R> onError, Func0<? extends R> onCompleted) final 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 withinNotification
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> Flattens two Singles into a single Observable, without any transformation.static <T> Observable
<T> 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
(Iterable<? extends Observable<? extends T>> sequences) Flattens an Iterable of 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
(Iterable<? extends Observable<? extends T>> sequences, int maxConcurrent) Flattens an Iterable of 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, while limiting the 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.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.final Observable
<T> Observable.mergeWith
(Observable<? extends T> t1) Flattens this and another Observable into a single Observable, without any transformation.final Observable
<T> Flattens this and another Single into a single Observable, without any transformation.final Observable
<Observable<T>> Observable.nest()
Converts the sourceObservable<T>
into anObservable<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 anObserver
.final Observable
<T> Modifies an Observable to perform its emissions and notifications on a specifiedScheduler
, asynchronously with a bounded buffer ofRxRingBuffer.SIZE
slots.final Observable
<T> Modifies an Observable to perform its emissions and notifications on a specifiedScheduler
, asynchronously with a bounded buffer and optionally delays onError notifications.final Observable
<T> Modifies an Observable to perform its emissions and notifications on a specifiedScheduler
, asynchronously with a bounded buffer of configurable size and optionally delays onError notifications.final Observable
<T> Modifies an Observable to perform its emissions and notifications on a specifiedScheduler
, asynchronously with a bounded buffer of configurable size.final <R> Observable
<R> Filters the items emitted by an Observable, only emitting those of the specified type.final 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.final 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.final 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.final Observable
<T> Observable.onBackpressureBuffer
(long capacity, Action0 onOverflow, BackpressureOverflow.Strategy overflowStrategy) 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.final 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.final 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.final 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.final Observable
<T> Observable.onErrorResumeNext
(Func1<Throwable, ? extends Observable<? extends T>> resumeFunction) Instructs an Observable to pass control to another Observable rather than invokingonError
if it encounters an error.final Observable
<T> Observable.onErrorResumeNext
(Observable<? extends T> resumeSequence) Instructs an Observable to pass control to another Observable rather than invokingonError
if it encounters an error.final Observable
<T> Observable.onErrorReturn
(Func1<Throwable, ? extends T> resumeFunction) Instructs an Observable to emit an item (returned by a specified function) rather than invokingonError
if it encounters an error.final Observable
<T> Observable.onExceptionResumeNext
(Observable<? extends T> resumeSequence) final Observable
<T> Observable.onTerminateDetach()
Nulls out references to the upstream producer and downstream Subscriber if the sequence is terminated or downstream unsubscribes.final <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 aConnectableObservable
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> Returns an Observable that emits a sequence of Integers within a specified range, on a specified Scheduler.final Observable
<T> Observable.rebatchRequests
(int n) Requestsn
initially from the upstream and then 75% ofn
subsequently after 75% ofn
values have been emitted to the downstream.final <R> Observable
<R> 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.final Observable
<T> 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.final Observable
<T> Observable.repeat()
Returns an Observable that repeats the sequence of items emitted by the source Observable indefinitely.final Observable
<T> Observable.repeat
(long count) Returns an Observable that repeats the sequence of items emitted by the source Observable at mostcount
times.final Observable
<T> Returns an Observable that repeats the sequence of items emitted by the source Observable at mostcount
times, on a particular Scheduler.final Observable
<T> Returns an Observable that repeats the sequence of items emitted by the source Observable indefinitely, on a particular Scheduler.final 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 anonCompleted
.final 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 anonCompleted
.final <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 aConnectableObservable
that shares a single subscription to the source Observable.final <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 aConnectableObservable
that shares a single subscription to the source Observable, replayingbufferSize
notifications.final <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 aConnectableObservable
that shares a single subscription to the source Observable, replaying no more thanbufferSize
items that were emitted within a specified time window.final <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 aConnectableObservable
that shares a single subscription to the source Observable, replaying no more thanbufferSize
items that were emitted within a specified time window.final <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 aConnectableObservable
that shares a single subscription to the source Observable, replaying a maximum ofbufferSize
items.final <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 aConnectableObservable
that shares a single subscription to the source Observable, replaying all items that were emitted within a specified time window.final <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 aConnectableObservable
that shares a single subscription to the source Observable, replaying all items that were emitted within a specified time window.final <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 aConnectableObservable
that shares a single subscription to the source Observable.final Observable
<T> Observable.retry()
Returns an Observable that mirrors the source Observable, resubscribing to it if it callsonError
(infinite retry count).final Observable
<T> Observable.retry
(long count) Returns an Observable that mirrors the source Observable, resubscribing to it if it callsonError
up to a specified number of retries.final Observable
<T> Returns an Observable that mirrors the source Observable, resubscribing to it if it callsonError
and the predicate returns true for that specific exception and retry count.final 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 anonError
.final 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 anonError
.final Observable
<T> Returns an Observable that emits the most recently emitted item (if any) emitted by the source Observable within periodic time intervals.final Observable
<T> 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.final <U> Observable
<T> Observable.sample
(Observable<U> sampler) Returns an Observable that, when the specifiedsampler
Observable emits an item or completes, emits the most recently emitted item (if any) emitted by the source Observable since the previous emission from thesampler
Observable.final <R> Observable
<R> 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.final Observable
<T> 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.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.final Observable
<T> Observable.serialize()
Forces an Observable's emissions and notifications to be serialized and for it to obey the Observable contract in other ways.final Observable
<T> Observable.share()
Returns a newObservable
that multicasts (shares) the originalObservable
.final 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.final Observable
<T> 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.final 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.final 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.final Observable
<T> Observable.skip
(int count) Returns an Observable that skips the firstcount
items emitted by the source Observable and emits the remainder.final Observable
<T> Returns an Observable that skips values emitted by the source Observable before a specified time window elapses.final Observable
<T> Returns an Observable that skips values emitted by the source Observable before a specified time window on a specifiedScheduler
elapses.final 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.final Observable
<T> Returns an Observable that drops items emitted by the source Observable during a specified time window before the source completes.final Observable
<T> 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.final <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.final Observable
<T> 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.final <T> Observable
<T> Completable.startWith
(Observable<T> other) Returns an Observable which first delivers the events of the other Observable then runs this Completable.final Observable
<T> Returns an Observable that emits the items in a specifiedIterable
before it begins to emit items emitted by the source Observable.final Observable
<T> Observable.startWith
(Observable<T> values) Returns an Observable that emits the items in a specifiedObservable
before it begins to emit items emitted by the source Observable.final Observable
<T> Returns an Observable that emits a specified item before it begins to emit items emitted by the source Observable.final Observable
<T> Returns an Observable that emits the specified items before it begins to emit items emitted by the source Observable.final Observable
<T> Returns an Observable that emits the specified items before it begins to emit items emitted by the source Observable.final Observable
<T> Returns an Observable that emits the specified items before it begins to emit items emitted by the source Observable.final Observable
<T> Returns an Observable that emits the specified items before it begins to emit items emitted by the source Observable.final Observable
<T> Returns an Observable that emits the specified items before it begins to emit items emitted by the source Observable.final Observable
<T> Returns an Observable that emits the specified items before it begins to emit items emitted by the source Observable.final Observable
<T> Returns an Observable that emits the specified items before it begins to emit items emitted by the source Observable.final Observable
<T> Returns an Observable that emits the specified items before it begins to emit items emitted by the source Observable.final Observable
<T> Observable.subscribeOn
(Scheduler scheduler) Asynchronously subscribes Observers to this Observable on the specifiedScheduler
.final 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.final <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.final <R> Observable
<R> Observable.switchMapDelayError
(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 and delays any error until all Observables terminate.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.static <T> Observable
<T> Observable.switchOnNextDelayError
(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 and delays any exception until all Observables terminate.final Observable
<T> Observable.take
(int count) Returns an Observable that emits only the firstcount
items emitted by the source Observable.final Observable
<T> Returns an Observable that emits those items emitted by source Observable before a specified time runs out.final Observable
<T> Returns an Observable that emits those items emitted by source Observable before a specified time (on a specified Scheduler) runs out.final Observable
<T> Returns an Observable that emits only the very first item emitted by the source Observable that satisfies a specified condition.final Observable
<T> Observable.takeLast
(int count) Returns an Observable that emits at most the lastcount
items emitted by the source Observable.final Observable
<T> 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.final Observable
<T> 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.final Observable
<T> Returns an Observable that emits the items from the source Observable that were emitted in a specified window of time before the Observable completed.final Observable
<T> 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.final Observable
<List<T>> Observable.takeLastBuffer
(int count) Returns an Observable that emits a single List containing at most the lastcount
elements emitted by the source Observable.final Observable
<List<T>> Observable.takeLastBuffer
(int count, long time, TimeUnit unit) Returns an Observable that emits a single List containing at mostcount
items from the source Observable that were emitted during a specified window of time before the source Observable completed.final Observable
<List<T>> Observable.takeLastBuffer
(int count, long time, TimeUnit unit, Scheduler scheduler) Returns an Observable that emits a single List containing at mostcount
items from the source Observable that were emitted during a specified window of time (on a specified Scheduler) before the source Observable completed.final 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.final 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.final Observable
<T> 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.final <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.final Observable
<T> 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.final 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.final 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.final 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.final 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.final 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.final 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.final Observable
<TimeInterval<T>> Observable.timeInterval()
Returns an Observable that emits records of the time interval between consecutive items emitted by the source Observable.final 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.final Observable
<T> Returns an Observable that mirrors the source Observable but applies a timeout policy for each emitted item.final 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.final 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.final Observable
<T> 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.final <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 aTimeoutException
if either the first item emitted by the source Observable or any subsequent item doesn't arrive within time windows defined by other Observables.final <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.final <V> Observable
<T> Observable.timeout
(Func1<? super T, ? extends Observable<V>> timeoutSelector) Returns an Observable that mirrors the source Observable, but notifies observers of aTimeoutException
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.final <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 Observable
<Long> Deprecated.useinterval(long, long, TimeUnit)
insteadstatic Observable
<Long> Deprecated.useinterval(long, long, TimeUnit, Scheduler)
insteadstatic Observable
<Long> Returns an Observable that emits one item after a specified delay, and then completes.static Observable
<Long> Returns an Observable that emits one item after a specified delay, on a specified Scheduler, and then completes.final Observable
<Timestamped<T>> Observable.timestamp()
Returns an Observable that emits each item emitted by the source Observable, wrapped in aTimestamped
object.final Observable
<Timestamped<T>> Returns an Observable that emits each item emitted by the source Observable, wrapped in aTimestamped
object whose timestamps are provided by a specified Scheduler.final 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.final <K> Observable
<Map<K, T>> Returns an Observable that emits a single HashMap containing all items emitted by the source Observable, mapped by the keys returned by a specifiedkeySelector
function.final <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 specifiedkeySelector
function.final <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 specifiedmapFactory
function, that contains keys and values extracted from the items emitted by the source Observable.final <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 specifiedkeySelector
function.final <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 specifiedvalueSelector
function from items emitted by the source Observable, keyed by a specifiedkeySelector
function.final <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 specifiedmapFactory
function, that contains an ArrayList of values, extracted by a specifiedvalueSelector
function from items emitted by the source Observable and keyed by thekeySelector
function.final <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 specifiedmapFactory
function, that contains a custom collection of values, extracted by a specifiedvalueSelector
function from items emitted by the source Observable, and keyed by thekeySelector
function.final <T> Observable
<T> Completable.toObservable()
Returns an Observable which when subscribed to subscribes to this Completable and relays the terminal events to the subscriber.final Observable
<T> Single.toObservable()
Converts this Single into anObservable
.final 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.final 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.final 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.final 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.final Observable
<T> Observable.unsubscribeOn
(Scheduler scheduler) Modifies the source Observable so that subscribers will unsubscribe from it on a specifiedScheduler
.static <T,
Resource>
Observable<T> 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<T> 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 setdisposeEagerly
totrue
and unsubscription does not occur before termination.final Observable
<Observable<T>> Observable.window
(int count) Returns an Observable that emits windows of items it collects from the source Observable.final Observable
<Observable<T>> Observable.window
(int count, int skip) Returns an Observable that emits windows of items it collects from the source Observable.final Observable
<Observable<T>> Returns an Observable that emits windows of items it collects from the source Observable.final Observable
<Observable<T>> Returns an Observable that emits windows of items it collects from the source Observable.final Observable
<Observable<T>> Returns an Observable that emits windows of items it collects from the source Observable.final Observable
<Observable<T>> Returns an Observable that emits windows of items it collects from the source Observable.final Observable
<Observable<T>> Returns an Observable that emits windows of items it collects from the source Observable.final Observable
<Observable<T>> Returns an Observable that emits windows of items it collects from the source Observable.final Observable
<Observable<T>> Returns an Observable that emits windows of items it collects from the source Observable.final <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.final <TOpening,
TClosing>
Observable<Observable<T>> 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.final <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.final <R> Observable
<R> Observable.withLatestFrom
(Iterable<Observable<?>> others, FuncN<R> combiner) Combines the value emission from this Observable with the latest emissions from the other Observables via a function to produce the output item.final <R> Observable
<R> Observable.withLatestFrom
(Observable<?>[] others, FuncN<R> combiner) Combines the value emission from this Observable with the latest emissions from the other Observables via a function to produce the output item.final <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 theresultSelector
function only when the source Observable (this instance) emits an item.final <T1,
T2, R>
Observable<R> Observable.withLatestFrom
(Observable<T1> o1, Observable<T2> o2, Func3<? super T, ? super T1, ? super T2, R> combiner) Combines the value emission from this Observable with the latest emissions from the other Observables via a function to produce the output item.final <T1,
T2, T3, T4, T5, R>
Observable<R> Observable.withLatestFrom
(Observable<T1> o1, Observable<T2> o2, Observable<T1> o3, Observable<T2> o4, Observable<T1> o5, Func6<? super T, ? super T1, ? super T2, ? super T3, ? super T4, ? super T5, R> combiner) Combines the value emission from this Observable with the latest emissions from the other Observables via a function to produce the output item.final <T1,
T2, T3, T4, T5, T6, R>
Observable<R> Observable.withLatestFrom
(Observable<T1> o1, Observable<T2> o2, Observable<T1> o3, Observable<T2> o4, Observable<T1> o5, Observable<T2> o6, Func7<? super T, ? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, R> combiner) Combines the value emission from this Observable with the latest emissions from the other Observables via a function to produce the output item.final <T1,
T2, T3, T4, T5, T6, T7, R>
Observable<R> Observable.withLatestFrom
(Observable<T1> o1, Observable<T2> o2, Observable<T1> o3, Observable<T2> o4, Observable<T1> o5, Observable<T2> o6, Observable<T1> o7, Func8<? super T, ? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, R> combiner) Combines the value emission from this Observable with the latest emissions from the other Observables via a function to produce the output item.final <T1,
T2, T3, T4, T5, T6, T7, T8, R>
Observable<R> Observable.withLatestFrom
(Observable<T1> o1, Observable<T2> o2, Observable<T1> o3, Observable<T2> o4, Observable<T1> o5, Observable<T2> o6, Observable<T1> o7, Observable<T2> o8, Func9<? super T, ? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, R> combiner) Combines the value emission from this Observable with the latest emissions from the other Observables via a function to produce the output item.final <T1,
T2, T3, R>
Observable<R> Observable.withLatestFrom
(Observable<T1> o1, Observable<T2> o2, Observable<T3> o3, Func4<? super T, ? super T1, ? super T2, ? super T3, R> combiner) Combines the value emission from this Observable with the latest emissions from the other Observables via a function to produce the output item.final <T1,
T2, T3, T4, R>
Observable<R> Observable.withLatestFrom
(Observable<T1> o1, Observable<T2> o2, Observable<T3> o3, Observable<T4> o4, Func5<? super T, ? super T1, ? super T2, ? super T3, ? super T4, R> combiner) Combines the value emission from this Observable with the latest emissions from the other Observables via a function to produce the output 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<?>[] 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 array 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<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<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<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<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<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<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<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.final <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.final <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.Methods in rx that return types with arguments of type ObservableModifier and TypeMethodDescriptionfinal Observable
<Observable<T>> Observable.nest()
Converts the sourceObservable<T>
into anObservable<Observable<T>>
that emits the source Observable as its single emission.private Single
<Observable<T>> Single.nest()
INTERNAL: Used with lift and operators.final Observable
<Observable<T>> Observable.window
(int count) Returns an Observable that emits windows of items it collects from the source Observable.final Observable
<Observable<T>> Observable.window
(int count, int skip) Returns an Observable that emits windows of items it collects from the source Observable.final Observable
<Observable<T>> Returns an Observable that emits windows of items it collects from the source Observable.final Observable
<Observable<T>> Returns an Observable that emits windows of items it collects from the source Observable.final Observable
<Observable<T>> Returns an Observable that emits windows of items it collects from the source Observable.final Observable
<Observable<T>> Returns an Observable that emits windows of items it collects from the source Observable.final Observable
<Observable<T>> Returns an Observable that emits windows of items it collects from the source Observable.final Observable
<Observable<T>> Returns an Observable that emits windows of items it collects from the source Observable.final Observable
<Observable<T>> Returns an Observable that emits windows of items it collects from the source Observable.final <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.final <TOpening,
TClosing>
Observable<Observable<T>> 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.final <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.Methods in rx with parameters of type ObservableModifier and TypeMethodDescriptionstatic <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.final 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.final <T> Observable
<T> Completable.andThen
(Observable<T> next) Returns an Observable which will subscribe to this Completable and once that is completed then will subscribe to thenext
Observable.final <TOpening,
TClosing>
Observable<List<T>> 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.final <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.final <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, T3, R>
Observable<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<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<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<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<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<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<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 Completable
Completable.concat
(Observable<? extends Completable> sources) Returns a Completable which completes only when all sources complete, one after another.static Completable
Completable.concat
(Observable<? extends Completable> sources, int prefetch) Returns a Completable which completes only when all sources complete, one after another.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> Observable.concatDelayError
(Observable<? extends Observable<? extends T>> sources) Concatenates the Observable sequence of Observables into a single sequence by subscribing to each inner Observable, one after the other, one at a time and delays any errors till the all inner and the outer Observables terminate.static <T> Observable
<T> Observable.concatEager
(Observable<? extends Observable<? extends T>> sources) Concatenates an Observable sequence of Observables eagerly into a single stream of values.static <T> Observable
<T> Observable.concatEager
(Observable<? extends Observable<? extends T>> sources, int capacityHint) Concatenates an Observable sequence of Observables eagerly into a single stream of values.static <T> Observable
<T> Observable.concatEager
(Observable<? extends T> o1, Observable<? extends T> o2) Concatenates two source Observables eagerly into a single stream of values.static <T> Observable
<T> Observable.concatEager
(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3) Concatenates three sources eagerly into a single stream of values.static <T> Observable
<T> Observable.concatEager
(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4) Concatenates four sources eagerly into a single stream of values.static <T> Observable
<T> Observable.concatEager
(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5) Concatenates five sources eagerly into a single stream of values.static <T> Observable
<T> Observable.concatEager
(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5, Observable<? extends T> o6) Concatenates six sources eagerly into a single stream of values.static <T> Observable
<T> Observable.concatEager
(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) Concatenates seven sources eagerly into a single stream of values.static <T> Observable
<T> Observable.concatEager
(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) Concatenates eight sources eagerly into a single stream of values.static <T> Observable
<T> Observable.concatEager
(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) Concatenates nine sources eagerly into a single stream of values.final 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.final <U> Observable
<T> Observable.delaySubscription
(Observable<U> other) Returns an Observable that delays the subscription to this Observable until the other Observable emits an element or completes normally.Single.delaySubscription
(Observable<?> other) Returns a Single that delays the subscription to this Single until the Observable completes.final <T> Observable
<T> Completable.endWith
(Observable<T> next) Deprecated.UseCompletable.andThen(rx.Observable)
instead.static Completable
Completable.fromObservable
(Observable<?> flowable) Returns a Completable instance that subscribes to the given flowable, ignores all values and emits only the terminal event.final <T2,
D1, D2, R>
Observable<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.final <TRight,
TLeftDuration, TRightDuration, R>
Observable<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 Completable
Completable.merge
(Observable<? extends Completable> sources) Returns a Completable instance that subscribes to all sources at once and completes only when all source Completables complete or one of them emits an error.static Completable
Completable.merge
(Observable<? extends Completable> sources, int maxConcurrency) Returns a Completable instance that keeps subscriptions to a limited number of sources at once and completes only when all source Completables complete or one of them emits an error.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.protected static Completable
Completable.merge0
(Observable<? extends Completable> sources, int maxConcurrency, boolean delayErrors) Returns a Completable instance that keeps subscriptions to a limited number of sources at once and completes only when all source Completables terminate in one way or another, combining any exceptions thrown by either the sources Observable or the inner Completable instances.static Completable
Completable.mergeDelayError
(Observable<? extends Completable> sources) Returns a Completable that subscribes to all Completables in the source sequence and delays any error emitted by either the sources observable or any of the inner Completables until all of them terminate in a way or another.static Completable
Completable.mergeDelayError
(Observable<? extends Completable> sources, int maxConcurrency) Returns a Completable that subscribes to a limited number of inner Completables at once in the source sequence and delays any error emitted by either the sources observable or any of the inner Completables until all of them terminate in a way or another.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.final Observable
<T> Observable.mergeWith
(Observable<? extends T> t1) Flattens this and another Observable into a single Observable, without any transformation.final Observable
<T> Observable.onErrorResumeNext
(Observable<? extends T> resumeSequence) Instructs an Observable to pass control to another Observable rather than invokingonError
if it encounters an error.final Observable
<T> Observable.onExceptionResumeNext
(Observable<? extends T> resumeSequence) final <U> Observable
<T> Observable.sample
(Observable<U> sampler) Returns an Observable that, when the specifiedsampler
Observable emits an item or completes, emits the most recently emitted item (if any) emitted by the source Observable since the previous emission from thesampler
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, 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.final <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.final <T> Observable
<T> Completable.startWith
(Observable<T> other) Returns an Observable which first delivers the events of the other Observable then runs this Completable.final Observable
<T> Observable.startWith
(Observable<T> values) Returns an Observable that emits the items in a specifiedObservable
before it begins to emit items emitted by the source Observable.(package private) static <T> Subscription
Observable.subscribe
(Subscriber<? super T> subscriber, Observable<T> observable) final 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.static <T> Observable
<T> Observable.switchOnNextDelayError
(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 and delays any exception until all Observables terminate.final <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.Single.takeUntil
(Observable<? extends E> other) Returns a Single that emits the item emitted by the source Single until an Observable emits an item.final 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.final 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.final <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.final <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.final <TOpening,
TClosing>
Observable<Observable<T>> 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.final <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.final <R> Observable
<R> Observable.withLatestFrom
(Observable<?>[] others, FuncN<R> combiner) Combines the value emission from this Observable with the latest emissions from the other Observables via a function to produce the output item.final <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 theresultSelector
function only when the source Observable (this instance) emits an item.final <T1,
T2, R>
Observable<R> Observable.withLatestFrom
(Observable<T1> o1, Observable<T2> o2, Func3<? super T, ? super T1, ? super T2, R> combiner) Combines the value emission from this Observable with the latest emissions from the other Observables via a function to produce the output item.final <T1,
T2, T3, T4, T5, R>
Observable<R> Observable.withLatestFrom
(Observable<T1> o1, Observable<T2> o2, Observable<T1> o3, Observable<T2> o4, Observable<T1> o5, Func6<? super T, ? super T1, ? super T2, ? super T3, ? super T4, ? super T5, R> combiner) Combines the value emission from this Observable with the latest emissions from the other Observables via a function to produce the output item.final <T1,
T2, T3, T4, T5, T6, R>
Observable<R> Observable.withLatestFrom
(Observable<T1> o1, Observable<T2> o2, Observable<T1> o3, Observable<T2> o4, Observable<T1> o5, Observable<T2> o6, Func7<? super T, ? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, R> combiner) Combines the value emission from this Observable with the latest emissions from the other Observables via a function to produce the output item.final <T1,
T2, T3, T4, T5, T6, T7, R>
Observable<R> Observable.withLatestFrom
(Observable<T1> o1, Observable<T2> o2, Observable<T1> o3, Observable<T2> o4, Observable<T1> o5, Observable<T2> o6, Observable<T1> o7, Func8<? super T, ? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, R> combiner) Combines the value emission from this Observable with the latest emissions from the other Observables via a function to produce the output item.final <T1,
T2, T3, T4, T5, T6, T7, T8, R>
Observable<R> Observable.withLatestFrom
(Observable<T1> o1, Observable<T2> o2, Observable<T1> o3, Observable<T2> o4, Observable<T1> o5, Observable<T2> o6, Observable<T1> o7, Observable<T2> o8, Func9<? super T, ? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, R> combiner) Combines the value emission from this Observable with the latest emissions from the other Observables via a function to produce the output item.final <T1,
T2, T3, R>
Observable<R> Observable.withLatestFrom
(Observable<T1> o1, Observable<T2> o2, Observable<T3> o3, Func4<? super T, ? super T1, ? super T2, ? super T3, R> combiner) Combines the value emission from this Observable with the latest emissions from the other Observables via a function to produce the output item.final <T1,
T2, T3, T4, R>
Observable<R> Observable.withLatestFrom
(Observable<T1> o1, Observable<T2> o2, Observable<T3> o3, Observable<T4> o4, Func5<? super T, ? super T1, ? super T2, ? super T3, ? super T4, R> combiner) Combines the value emission from this Observable with the latest emissions from the other Observables via a function to produce the output item.static <R> Observable
<R> Observable.zip
(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 array 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<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<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<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<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<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<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<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.final <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.Method parameters in rx with type arguments of type ObservableModifier and TypeMethodDescriptionstatic <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.final <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.final <TOpening,
TClosing>
Observable<List<T>> 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
(Iterable<? extends Observable<? extends T>> sources, FuncN<? extends R> combineFunction) Combines a collection 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,
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,
R> Observable <R> Observable.combineLatestDelayError
(Iterable<? extends Observable<? extends T>> sources, FuncN<? extends R> combineFunction) Combines a collection 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 and delays any error from the sources until all source Observables terminate.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.concatDelayError
(Iterable<? extends Observable<? extends T>> sources) Concatenates the Iterable sequence of Observables into a single sequence by subscribing to each Observable, one after the other, one at a time and delays any errors till the all inner Observables terminate.static <T> Observable
<T> Observable.concatDelayError
(Observable<? extends Observable<? extends T>> sources) Concatenates the Observable sequence of Observables into a single sequence by subscribing to each inner Observable, one after the other, one at a time and delays any errors till the all inner and the outer Observables terminate.static <T> Observable
<T> Observable.concatEager
(Iterable<? extends Observable<? extends T>> sources) Concatenates a sequence of Observables eagerly into a single stream of values.static <T> Observable
<T> Observable.concatEager
(Iterable<? extends Observable<? extends T>> sources, int capacityHint) Concatenates a sequence of Observables eagerly into a single stream of values.static <T> Observable
<T> Observable.concatEager
(Observable<? extends Observable<? extends T>> sources) Concatenates an Observable sequence of Observables eagerly into a single stream of values.static <T> Observable
<T> Observable.concatEager
(Observable<? extends Observable<? extends T>> sources, int capacityHint) Concatenates an Observable sequence of Observables eagerly into a single stream of values.final <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 concatenating those resulting Observables.final <R> Observable
<R> Observable.concatMapDelayError
(Func1<? super T, ? extends Observable<? extends R>> func) Maps each of the items into an Observable, subscribes to them one after the other, one at a time and emits their values in order while delaying any error from either this or any of the inner Observables till all of them terminate.final <R> Observable
<R> Observable.concatMapEager
(Func1<? super T, ? extends Observable<? extends R>> mapper) Maps a sequence of values into Observables and concatenates these Observables eagerly into a single Observable.final <R> Observable
<R> Observable.concatMapEager
(Func1<? super T, ? extends Observable<? extends R>> mapper, int capacityHint) Maps a sequence of values into Observables and concatenates these Observables eagerly into a single Observable.final <R> Observable
<R> Observable.concatMapEager
(Func1<? super T, ? extends Observable<? extends R>> mapper, int capacityHint, int maxConcurrent) Maps a sequence of values into Observables and concatenates these Observables eagerly into a single Observable.final <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.final <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 source Observable via another Observable on a per-item basis.final <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 source Observable via another Observable on a per-item basis.final <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.final <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.final <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.final <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.final <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.final <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.final <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.final <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.final <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.final <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.final <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.final <T2,
D1, D2, R>
Observable<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.final <T2,
D1, D2, R>
Observable<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.final <TRight,
TLeftDuration, TRightDuration, R>
Observable<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
(Iterable<? extends Observable<? extends T>> sequences) Flattens an Iterable of 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
(Iterable<? extends Observable<? extends T>> sequences, int maxConcurrent) Flattens an Iterable of 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, while limiting the 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.final Observable
<T> Observable.onErrorResumeNext
(Func1<Throwable, ? extends Observable<? extends T>> resumeFunction) Instructs an Observable to pass control to another Observable rather than invokingonError
if it encounters an error.final <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 aConnectableObservable
that shares a single subscription to the underlying sequence.final <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 aConnectableObservable
that shares a single subscription to the underlying sequence.final Completable
Completable.repeatWhen
(Func1<? super Observable<? extends Void>, ? extends Observable<?>> handler) Returns a Completable instance that repeats when the Publisher returned by the handler emits an item or completes when this Publisher emits a completed event.final Completable
Completable.repeatWhen
(Func1<? super Observable<? extends Void>, ? extends Observable<?>> handler) Returns a Completable instance that repeats when the Publisher returned by the handler emits an item or completes when this Publisher emits a completed event.final 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 anonCompleted
.final 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 anonCompleted
.final 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 anonCompleted
.final 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 anonCompleted
.final <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 aConnectableObservable
that shares a single subscription to the source Observable.final <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 aConnectableObservable
that shares a single subscription to the source Observable.final <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 aConnectableObservable
that shares a single subscription to the source Observable, replayingbufferSize
notifications.final <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 aConnectableObservable
that shares a single subscription to the source Observable, replayingbufferSize
notifications.final <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 aConnectableObservable
that shares a single subscription to the source Observable, replaying no more thanbufferSize
items that were emitted within a specified time window.final <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 aConnectableObservable
that shares a single subscription to the source Observable, replaying no more thanbufferSize
items that were emitted within a specified time window.final <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 aConnectableObservable
that shares a single subscription to the source Observable, replaying no more thanbufferSize
items that were emitted within a specified time window.final <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 aConnectableObservable
that shares a single subscription to the source Observable, replaying no more thanbufferSize
items that were emitted within a specified time window.final <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 aConnectableObservable
that shares a single subscription to the source Observable, replaying a maximum ofbufferSize
items.final <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 aConnectableObservable
that shares a single subscription to the source Observable, replaying a maximum ofbufferSize
items.final <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 aConnectableObservable
that shares a single subscription to the source Observable, replaying all items that were emitted within a specified time window.final <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 aConnectableObservable
that shares a single subscription to the source Observable, replaying all items that were emitted within a specified time window.final <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 aConnectableObservable
that shares a single subscription to the source Observable, replaying all items that were emitted within a specified time window.final <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 aConnectableObservable
that shares a single subscription to the source Observable, replaying all items that were emitted within a specified time window.final <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 aConnectableObservable
that shares a single subscription to the source Observable.final <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 aConnectableObservable
that shares a single subscription to the source Observable.final Completable
Completable.retryWhen
(Func1<? super Observable<? extends Throwable>, ? extends Observable<?>> handler) Returns a Completable which given a Publisher and when this Completable emits an error, delivers that error through an Observable and the Publisher should return a value indicating a retry in response or a terminal event indicating a termination.final Completable
Completable.retryWhen
(Func1<? super Observable<? extends Throwable>, ? extends Observable<?>> handler) Returns a Completable which given a Publisher and when this Completable emits an error, delivers that error through an Observable and the Publisher should return a value indicating a retry in response or a terminal event indicating a termination.final 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 anonError
.final 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 anonError
.final 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 anonError
.final 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 anonError
.Single.retryWhen
(Func1<Observable<? extends Throwable>, ? extends Observable<?>> notificationHandler) Returns a Single that emits the same values as the source Single with the exception of anonError
.Single.retryWhen
(Func1<Observable<? extends Throwable>, ? extends Observable<?>> notificationHandler) Returns a Single that emits the same values as the source Single with the exception of anonError
.final <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.final <R> Observable
<R> Observable.switchMapDelayError
(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 and delays any error until all Observables terminate.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.static <T> Observable
<T> Observable.switchOnNextDelayError
(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 and delays any exception until all Observables terminate.final <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 aTimeoutException
if either the first item emitted by the source Observable or any subsequent item doesn't arrive within time windows defined by other Observables.final <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 aTimeoutException
if either the first item emitted by the source Observable or any subsequent item doesn't arrive within time windows defined by other Observables.final <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.final <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.final <V> Observable
<T> Observable.timeout
(Func1<? super T, ? extends Observable<V>> timeoutSelector) Returns an Observable that mirrors the source Observable, but notifies observers of aTimeoutException
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.final <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<T> 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<T> 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 setdisposeEagerly
totrue
and unsubscription does not occur before termination.<S extends Scheduler & Subscription>
SScheduler.when
(Func1<Observable<Observable<Completable>>, Completable> combine) Allows the use of operators for controlling the timing around when actions scheduled on workers are actually done.<S extends Scheduler & Subscription>
SScheduler.when
(Func1<Observable<Observable<Completable>>, Completable> combine) Allows the use of operators for controlling the timing around when actions scheduled on workers are actually done.final <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.final <TOpening,
TClosing>
Observable<Observable<T>> 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.final <R> Observable
<R> Observable.withLatestFrom
(Iterable<Observable<?>> others, FuncN<R> combiner) Combines the value emission from this Observable with the latest emissions from the other Observables via a function to produce the output 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.Constructors in rx with parameters of type Observable -
Uses of Observable in rx.internal.operators
Subclasses of Observable in rx.internal.operatorsModifier and TypeClassDescriptionfinal class
A solution to the "time gap" problem that occurs withgroupBy
andpivot
.final class
An observable which auto-connects to another observable, caches the elements from that observable but allows terminating the connection and completing the cache.(package private) static final class
final class
OperatorMulticast<T,
R> Shares a single subscription to a source through a Subject.final class
A connectable observable which shares an underlying source and dispatches source values to subscribers in a backpressure-aware manner.final class
Fields in rx.internal.operators declared as ObservableModifier and TypeFieldDescriptionprivate final Observable
<? extends T> OperatorSwitchIfEmpty.alternate
private final Observable
<? extends T> OperatorSwitchIfEmpty.ParentSubscriber.alternate
(package private) final Observable
<? extends TOpening> OperatorBufferWithStartEndObservable.bufferOpening
(package private) static final Observable
<Object> EmptyObservableHolder.EMPTY
The singleton instance.private final Observable
<? extends T> BlockingOperatorNext.NextIterator.items
(package private) final Observable
<T1> OnSubscribeGroupJoin.left
(package private) final Observable
<TLeft> OnSubscribeJoin.left
(package private) final Observable
<? extends T> OnSubscribeDelaySubscriptionOther.main
(package private) final Observable
<T> OperatorWithLatestFromMany.main
(package private) static final Observable
<Object> NeverObservableHolder.NEVER
The singleton instance.private final Observable
<T> OnSubscribeSingle.observable
(package private) final Observable
<U> OnSubscribeDelaySubscriptionOther.other
(package private) final Observable
<U> OperatorSkipUntil.other
private final Observable
<? extends E> OperatorTakeUntil.other
(package private) final Observable
<? extends T> OperatorTimeoutBase.other
(package private) final Observable
<? extends T> OperatorTimeoutBase.TimeoutSubscriber.other
(package private) final Observable
<U> OperatorWindowWithObservable.other
(package private) final Observable
<? extends U> OperatorWithLatestFrom.other
(package private) final Observable
<?> SingleOnSubscribeDelaySubscriptionOther.other
(package private) final Observable<?>[]
OperatorWithLatestFromMany.others
(package private) Observable
<T> OperatorWindowWithObservable.SourceSubscriber.producer
Accessed from the serialized part.(package private) Observable
<T> OperatorWindowWithObservableFactory.SourceSubscriber.producer
Accessed from the serialized part.(package private) final Observable
<T> OperatorWindowWithStartEndObservable.SerializedSubject.producer
(package private) final Observable
<T> OperatorWindowWithTime.CountedSerializedSubject.producer
(package private) final Observable
<T> OperatorWindowWithTime.State.producer
(package private) final Observable
<T2> OnSubscribeGroupJoin.right
(package private) final Observable
<TRight> OnSubscribeJoin.right
(package private) final Observable
<U> OperatorSampleWithObservable.sampler
(package private) final Observable
<? extends T> CachedObservable.CacheState.source
The source observable to connect to.(package private) final Observable
<Completable> CompletableOnSubscribeMerge.source
(package private) final Observable
<T> OnSubscribeCollect.source
(package private) final Observable
<? extends T> OnSubscribeConcatMap.source
(package private) final Observable
<? extends T> OnSubscribeDelaySubscription.source
(package private) final Observable
<? extends T> OnSubscribeDelaySubscriptionWithSelector.source
(package private) final Observable
<T> OnSubscribeDetach.source
(package private) final Observable
<T> OnSubscribeFilter.source
(package private) final Observable
<? extends T> OnSubscribeFlattenIterable.source
(package private) final Observable
<T> OnSubscribeMap.source
(package private) final Observable
<T> OnSubscribeRedo.source
(package private) final Observable
<T> OnSubscribeReduce.source
(package private) final Observable
<T> OnSubscribeReduceSeed.source
(package private) final Observable
<T> OnSubscribeTakeLastOne.source
(package private) final Observable
<? extends T> OperatorDelayWithSelector.source
(package private) final Observable
<? extends T> OperatorMulticast.source
(package private) final Observable
<? extends T> OperatorPublish.source
The source observable.(package private) final Observable
<? extends T> OperatorReplay.source
The source observable.(package private) final Observable
<T> OperatorSubscribeOn.source
(package private) final Observable
<Completable> CompletableOnSubscribeConcat.sources
(package private) final Observable<? extends T>[]
OnSubscribeCombineLatest.sources
(package private) final Observable
<T> OnSubscribeGroupJoin.WindowObservableFunc.underlying
(package private) final Observable
<? extends U> OperatorWindowWithStartEndObservable.windowOpenings
Fields in rx.internal.operators with type parameters of type ObservableModifier and TypeFieldDescription(package private) final Subscriber
<? super Observable<? extends R>> OperatorMapPair.MapPairSubscriber.actual
(package private) final Subscriber
<? super Observable<T>> OperatorWindowWithSize.WindowExact.actual
(package private) final Subscriber
<? super Observable<T>> OperatorWindowWithSize.WindowOverlap.actual
(package private) final Subscriber
<? super Observable<T>> OperatorWindowWithSize.WindowSkip.actual
(package private) final Func1
<? super TOpening, ? extends Observable<? extends TClosing>> OperatorBufferWithStartEndObservable.bufferClosing
(package private) final Func0
<? extends Observable<? extends TClosing>> OperatorBufferWithSingleObservable.bufferClosingSelector
(package private) final Subscriber
<? super Observable<T>> OperatorWindowWithObservable.SourceSubscriber.child
(package private) final Subscriber
<? super Observable<T>> OperatorWindowWithObservableFactory.SourceSubscriber.child
(package private) final Subscriber
<? super Observable<T>> OperatorWindowWithStartEndObservable.SourceSubscriber.child
(package private) final Subscriber
<? super Observable<T>> OperatorWindowWithTime.ExactSubscriber.child
(package private) final Subscriber
<? super Observable<T>> OperatorWindowWithTime.InexactSubscriber.child
(package private) final Func1
<? super T, ? extends Observable<? extends U>> OperatorMapPair.collectionSelector
(package private) final Func1
<? super T, ? extends Observable<? extends U>> OperatorMapPair.MapPairSubscriber.collectionSelector
private final Func1
<? super Observable<? extends Notification<?>>, ? extends Observable<?>> OnSubscribeRedo.controlHandlerFunction
private final Func1
<? super Observable<? extends Notification<?>>, ? extends Observable<?>> OnSubscribeRedo.controlHandlerFunction
(package private) final Func1
<? super T, ? extends Observable<V>> OperatorDelayWithSelector.itemDelay
(package private) final Func1
<? super T1, ? extends Observable<D1>> OnSubscribeGroupJoin.leftDuration
(package private) final Func1
<TLeft, Observable<TLeftDuration>> OnSubscribeJoin.leftDurationSelector
(package private) final Func1
<? super T, ? extends Observable<? extends R>> OnSubscribeConcatMap.ConcatMapSubscriber.mapper
(package private) final Func1
<? super T, ? extends Observable<? extends R>> OnSubscribeConcatMap.mapper
(package private) final Func1
<? super T, ? extends Observable<? extends R>> OperatorEagerConcatMap.EagerOuterSubscriber.mapper
(package private) final Func1
<? super T, ? extends Observable<? extends R>> OperatorEagerConcatMap.mapper
(package private) final Func0
<? extends Observable<? extends T>> OnSubscribeDefer.observableFactory
private final Func1
<? super Resource, ? extends Observable<? extends T>> OnSubscribeUsing.observableFactory
(package private) final Func0
<? extends Observable<? extends U>> OperatorWindowWithObservableFactory.otherFactory
(package private) final Func0
<? extends Observable<? extends U>> OperatorWindowWithObservableFactory.SourceSubscriber.otherFactory
(package private) final Iterable
<Observable<?>> OperatorWithLatestFromMany.othersIterable
(package private) static final Func1
<Observable<? extends Notification<?>>, Observable<?>> OnSubscribeRedo.REDO_INFINITE
(package private) static final Func1
<Observable<? extends Notification<?>>, Observable<?>> OnSubscribeRedo.REDO_INFINITE
(package private) final Func2
<? super T1, ? super Observable<T2>, ? extends R> OnSubscribeGroupJoin.resultSelector
(package private) final Func1
<Throwable, ? extends Observable<? extends T>> OperatorOnErrorResumeNextViaFunction.resumeFunction
(package private) final Func1
<? super T2, ? extends Observable<D2>> OnSubscribeGroupJoin.rightDuration
(package private) final Func1
<TRight, Observable<TRightDuration>> OnSubscribeJoin.rightDurationSelector
(package private) final Func1
<? super T, ? extends Observable<U>> OperatorDebounceWithSelector.selector
(package private) final Iterable
<? extends Observable<? extends T>> OnSubscribeAmb.sources
(package private) final Iterable
<? extends Observable<? extends T>> OnSubscribeCombineLatest.sourcesIterable
(package private) final Func0
<? extends Observable<U>> OnSubscribeDelaySubscriptionWithSelector.subscriptionDelay
(package private) final Func1
<? super U, ? extends Observable<? extends V>> OperatorWindowWithStartEndObservable.windowClosingSelector
Methods in rx.internal.operators that return ObservableModifier and TypeMethodDescriptionObservable
<?> OnSubscribeRedo.RedoFinite.call
(Observable<? extends Notification<?>> ts) Observable
<? extends Notification<?>> OnSubscribeRedo.RetryWithPredicate.call
(Observable<? extends Notification<?>> ts) static <T,
R> Observable <R> OperatorPublish.create
(Observable<? extends T> source, Func1<? super Observable<T>, ? extends Observable<R>> selector) static <T,
R> Observable <R> OperatorPublish.create
(Observable<? extends T> source, Func1<? super Observable<T>, ? extends Observable<R>> selector, boolean delayError) static <T,
R> Observable <R> OnSubscribeFlattenIterable.createFrom
(Observable<? extends T> source, Func1<? super T, ? extends Iterable<? extends R>> mapper, int prefetch) static <T> Observable
<T> EmptyObservableHolder.instance()
Returns a type-corrected singleton instance of the empty Observable.static <T> Observable
<T> NeverObservableHolder.instance()
Returns a type-corrected singleton instance of the never Observable.(package private) static <T> Observable
<Object> OperatorSequenceEqual.materializeLite
(Observable<T> source) static <T,
U, R> Observable <R> OperatorReplay.multicastSelector
(Func0<? extends ConnectableObservable<U>> connectableFactory, Func1<? super Observable<U>, ? extends Observable<R>> selector) Given a connectable observable factory, it multicasts over the generated ConnectableObservable via a selector function.static <T> Observable
<T> OnSubscribeRedo.redo
(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler, Scheduler scheduler) static <T> Observable
<T> OnSubscribeRedo.repeat
(Observable<T> source) static <T> Observable
<T> OnSubscribeRedo.repeat
(Observable<T> source, long count) static <T> Observable
<T> OnSubscribeRedo.repeat
(Observable<T> source, long count, Scheduler scheduler) static <T> Observable
<T> OnSubscribeRedo.repeat
(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler) static <T> Observable
<T> OnSubscribeRedo.repeat
(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler, Scheduler scheduler) static <T> Observable
<T> OnSubscribeRedo.repeat
(Observable<T> source, Scheduler scheduler) static <T> Observable
<T> OnSubscribeRedo.retry
(Observable<T> source) static <T> Observable
<T> OnSubscribeRedo.retry
(Observable<T> source, long count) static <T> Observable
<T> OnSubscribeRedo.retry
(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler) static <T> Observable
<T> OnSubscribeRedo.retry
(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler, Scheduler scheduler) static <T> Observable
<Boolean> OperatorSequenceEqual.sequenceEqual
(Observable<? extends T> first, Observable<? extends T> second, Func2<? super T, ? super T, Boolean> equality) Tests whether twoObservable
sequences are identical, emittingtrue
if both sequences complete without differing, andfalse
if the two sequences diverge at any point.Methods in rx.internal.operators that return types with arguments of type ObservableModifier and TypeMethodDescriptionSubscriber
<Observable<? extends T>> OperatorMerge.call
(Subscriber<? super T> child) Subscriber
<? super Observable<T>> OperatorRetryWithPredicate.call
(Subscriber<? super T> child) Subscriber
<? super Observable<? extends T>> OperatorSwitch.call
(Subscriber<? super T> child) static <T,
U> Func1 <T, Observable<U>> OperatorMapPair.convertSelector
(Func1<? super T, ? extends Iterable<? extends U>> selector) Creates the function that generates aObservable
based on an item emitted by anotherObservable
.Methods in rx.internal.operators with parameters of type ObservableModifier and TypeMethodDescriptionstatic <T> Observable.OnSubscribe
<T> OnSubscribeAmb.amb
(Observable<? extends T> o1, Observable<? extends T> o2) Given twoObservable
s, propagates the one that first emits an item.static <T> Observable.OnSubscribe
<T> OnSubscribeAmb.amb
(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3) Given threeObservable
s, propagates the one that first emits an item.static <T> Observable.OnSubscribe
<T> OnSubscribeAmb.amb
(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4) Given fourObservable
s, propagates the one that first emits an item.static <T> Observable.OnSubscribe
<T> OnSubscribeAmb.amb
(Observable<? extends T> o1, Observable<? extends T> o2, Observable<? extends T> o3, Observable<? extends T> o4, Observable<? extends T> o5) Given fiveObservable
s, propagates the one that first emits an item.static <T> Observable.OnSubscribe
<T> OnSubscribeAmb.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 sixObservable
s, propagates the one that first emits an item.static <T> Observable.OnSubscribe
<T> OnSubscribeAmb.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 sevenObservable
s, propagates the one that first emits an item.static <T> Observable.OnSubscribe
<T> OnSubscribeAmb.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 eightObservable
s, propagates the one that first emits an item.static <T> Observable.OnSubscribe
<T> OnSubscribeAmb.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 nineObservable
s, propagates the one that first emits an item.Observable
<?> OnSubscribeRedo.RedoFinite.call
(Observable<? extends Notification<?>> ts) Observable
<? extends Notification<?>> OnSubscribeRedo.RetryWithPredicate.call
(Observable<? extends Notification<?>> ts) static <T> OnSubscribeSingle
<T> OnSubscribeSingle.create
(Observable<T> observable) static <T> ConnectableObservable
<T> OperatorPublish.create
(Observable<? extends T> source) Creates a OperatorPublish instance to publish values of the given source observable.static <T,
R> Observable <R> OperatorPublish.create
(Observable<? extends T> source, Func1<? super Observable<T>, ? extends Observable<R>> selector) static <T,
R> Observable <R> OperatorPublish.create
(Observable<? extends T> source, Func1<? super Observable<T>, ? extends Observable<R>> selector, boolean delayError) static <T> ConnectableObservable
<T> OperatorReplay.create
(Observable<? extends T> source) Creates a replaying ConnectableObservable with an unbounded buffer.static <T> ConnectableObservable
<T> OperatorReplay.create
(Observable<? extends T> source, int bufferSize) Creates a replaying ConnectableObservable with a size bound buffer.static <T> ConnectableObservable
<T> OperatorReplay.create
(Observable<? extends T> source, long maxAge, TimeUnit unit, Scheduler scheduler) Creates a replaying ConnectableObservable with a time bound buffer.static <T> ConnectableObservable
<T> OperatorReplay.create
(Observable<? extends T> source, long maxAge, TimeUnit unit, Scheduler scheduler, int bufferSize) Creates a replaying ConnectableObservable with a size and time bound buffer.(package private) static <T> ConnectableObservable
<T> OperatorReplay.create
(Observable<? extends T> source, Func0<? extends OperatorReplay.ReplayBuffer<T>> bufferFactory) Creates a OperatorReplay instance to replay values of the given source observable.OperatorWindowWithTime.State.create
(Observer<T> consumer, Observable<T> producer) static <T,
R> Observable <R> OnSubscribeFlattenIterable.createFrom
(Observable<? extends T> source, Func1<? super T, ? extends Iterable<? extends R>> mapper, int prefetch) static <T> CachedObservable
<T> CachedObservable.from
(Observable<? extends T> source) Creates a cached Observable with a default capacity hint of 16.static <T> CachedObservable
<T> CachedObservable.from
(Observable<? extends T> source, int capacityHint) Creates a cached Observable with the given capacity hint.static <T> Iterable
<T> BlockingOperatorLatest.latest
(Observable<? extends T> source) Returns anIterable
that blocks until or unless theObservable
emits an item that has not been returned by theIterable
, then returns that item(package private) static <T> Observable
<Object> OperatorSequenceEqual.materializeLite
(Observable<T> source) static <T> Iterable
<T> BlockingOperatorMostRecent.mostRecent
(Observable<? extends T> source, T initialValue) Returns anIterable
that always returns the item most recently emitted by theObservable
.static <T> Iterable
<T> BlockingOperatorNext.next
(Observable<? extends T> items) Returns anIterable
that blocks until theObservable
emits another item, then returns that item.void
OperatorMerge.MergeSubscriber.onNext
(Observable<? extends T> t) void
OperatorRetryWithPredicate.SourceSubscriber.onNext
(Observable<T> o) void
OperatorSwitch.SwitchSubscriber.onNext
(Observable<? extends T> t) void
OperatorZip.ZipSubscriber.onNext
(Observable[] observables) static <T> Observable
<T> OnSubscribeRedo.redo
(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler, Scheduler scheduler) static <T> Observable
<T> OnSubscribeRedo.repeat
(Observable<T> source) static <T> Observable
<T> OnSubscribeRedo.repeat
(Observable<T> source, long count) static <T> Observable
<T> OnSubscribeRedo.repeat
(Observable<T> source, long count, Scheduler scheduler) static <T> Observable
<T> OnSubscribeRedo.repeat
(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler) static <T> Observable
<T> OnSubscribeRedo.repeat
(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler, Scheduler scheduler) static <T> Observable
<T> OnSubscribeRedo.repeat
(Observable<T> source, Scheduler scheduler) static <T> Observable
<T> OnSubscribeRedo.retry
(Observable<T> source) static <T> Observable
<T> OnSubscribeRedo.retry
(Observable<T> source, long count) static <T> Observable
<T> OnSubscribeRedo.retry
(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler) static <T> Observable
<T> OnSubscribeRedo.retry
(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler, Scheduler scheduler) static <T> Observable
<Boolean> OperatorSequenceEqual.sequenceEqual
(Observable<? extends T> first, Observable<? extends T> second, Func2<? super T, ? super T, Boolean> equality) Tests whether twoObservable
sequences are identical, emittingtrue
if both sequences complete without differing, andfalse
if the two sequences diverge at any point.void
OperatorZip.Zip.start
(Observable[] os, AtomicLong requested) void
OnSubscribeCombineLatest.LatestCoordinator.subscribe
(Observable<? extends T>[] sources) final void
DeferredScalarSubscriber.subscribeTo
(Observable<? extends T> source) Links up with the downstream Subscriber (cancellation, backpressure) and subscribes to the source Observable.static <T> Future
<T> BlockingOperatorToFuture.toFuture
(Observable<? extends T> that) Returns a Future that expects a single item from the observable.static <T> Iterator
<T> BlockingOperatorToIterator.toIterator
(Observable<? extends T> source) Returns an iterator that iterates all values of the observable.static <T> OperatorOnErrorResumeNextViaFunction
<T> OperatorOnErrorResumeNextViaFunction.withException
(Observable<? extends T> other) static <T> OperatorOnErrorResumeNextViaFunction
<T> OperatorOnErrorResumeNextViaFunction.withOther
(Observable<? extends T> other) Method parameters in rx.internal.operators with type arguments of type ObservableModifier and TypeMethodDescriptionstatic <T> Observable.OnSubscribe
<T> OnSubscribeAmb.amb
(Iterable<? extends Observable<? extends T>> sources) Given a set ofObservable
s, propagates the one that first emits an item.Subscriber
<? super T> OperatorMapPair.call
(Subscriber<? super Observable<? extends R>> o) Subscriber
<? super T> OperatorWindowWithObservable.call
(Subscriber<? super Observable<T>> child) Subscriber
<? super T> OperatorWindowWithObservableFactory.call
(Subscriber<? super Observable<T>> child) Subscriber
<? super T> OperatorWindowWithSize.call
(Subscriber<? super Observable<T>> child) Subscriber
<? super T> OperatorWindowWithStartEndObservable.call
(Subscriber<? super Observable<T>> child) Subscriber
<? super T> OperatorWindowWithTime.call
(Subscriber<? super Observable<T>> child) static <T,
R> Observable <R> OperatorPublish.create
(Observable<? extends T> source, Func1<? super Observable<T>, ? extends Observable<R>> selector) static <T,
R> Observable <R> OperatorPublish.create
(Observable<? extends T> source, Func1<? super Observable<T>, ? extends Observable<R>> selector) static <T,
R> Observable <R> OperatorPublish.create
(Observable<? extends T> source, Func1<? super Observable<T>, ? extends Observable<R>> selector, boolean delayError) static <T,
R> Observable <R> OperatorPublish.create
(Observable<? extends T> source, Func1<? super Observable<T>, ? extends Observable<R>> selector, boolean delayError) static <T,
U, R> Observable <R> OperatorReplay.multicastSelector
(Func0<? extends ConnectableObservable<U>> connectableFactory, Func1<? super Observable<U>, ? extends Observable<R>> selector) Given a connectable observable factory, it multicasts over the generated ConnectableObservable via a selector function.static <T,
U, R> Observable <R> OperatorReplay.multicastSelector
(Func0<? extends ConnectableObservable<U>> connectableFactory, Func1<? super Observable<U>, ? extends Observable<R>> selector) Given a connectable observable factory, it multicasts over the generated ConnectableObservable via a selector function.static <T> Observable
<T> OnSubscribeRedo.redo
(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler, Scheduler scheduler) static <T> Observable
<T> OnSubscribeRedo.redo
(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler, Scheduler scheduler) static <T> Observable
<T> OnSubscribeRedo.repeat
(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler) static <T> Observable
<T> OnSubscribeRedo.repeat
(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler) static <T> Observable
<T> OnSubscribeRedo.repeat
(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler, Scheduler scheduler) static <T> Observable
<T> OnSubscribeRedo.repeat
(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler, Scheduler scheduler) static <T> Observable
<T> OnSubscribeRedo.retry
(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler) static <T> Observable
<T> OnSubscribeRedo.retry
(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler) static <T> Observable
<T> OnSubscribeRedo.retry
(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler, Scheduler scheduler) static <T> Observable
<T> OnSubscribeRedo.retry
(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> notificationHandler, Scheduler scheduler) Constructors in rx.internal.operators with parameters of type ObservableModifierConstructorDescriptionCacheState
(Observable<? extends T> source, int capacityHint) CompletableOnSubscribeConcat
(Observable<? extends Completable> sources, int prefetch) CompletableOnSubscribeMerge
(Observable<? extends Completable> source, int maxConcurrency, boolean delayErrors) CountedSerializedSubject
(Observer<T> consumer, Observable<T> producer) (package private)
NextIterator
(Observable<? extends T> items, BlockingOperatorNext.NextObserver<T> observer) OnSubscribeCollect
(Observable<T> source, Func0<R> collectionFactory, Action2<R, ? super T> collector) OnSubscribeCombineLatest
(Observable<? extends T>[] sources, Iterable<? extends Observable<? extends T>> sourcesIterable, FuncN<? extends R> combiner, int bufferSize, boolean delayError) OnSubscribeConcatMap
(Observable<? extends T> source, Func1<? super T, ? extends Observable<? extends R>> mapper, int prefetch, int delayErrorMode) OnSubscribeDelaySubscription
(Observable<? extends T> source, long time, TimeUnit unit, Scheduler scheduler) OnSubscribeDelaySubscriptionOther
(Observable<? extends T> main, Observable<U> other) OnSubscribeDelaySubscriptionWithSelector
(Observable<? extends T> source, Func0<? extends Observable<U>> subscriptionDelay) OnSubscribeDetach
(Observable<T> source) OnSubscribeFilter
(Observable<T> source, Func1<? super T, Boolean> predicate) protected
OnSubscribeFlattenIterable
(Observable<? extends T> source, Func1<? super T, ? extends Iterable<? extends R>> mapper, int prefetch) Protected: use createFrom to handle source-dependent optimizations.OnSubscribeGroupJoin
(Observable<T1> left, Observable<T2> right, Func1<? super T1, ? extends Observable<D1>> leftDuration, Func1<? super T2, ? extends Observable<D2>> rightDuration, Func2<? super T1, ? super Observable<T2>, ? extends R> resultSelector) OnSubscribeJoin
(Observable<TLeft> left, Observable<TRight> right, Func1<TLeft, Observable<TLeftDuration>> leftDurationSelector, Func1<TRight, Observable<TRightDuration>> rightDurationSelector, Func2<TLeft, TRight, R> resultSelector) OnSubscribeMap
(Observable<T> source, Func1<? super T, ? extends R> transformer) private
OnSubscribeRedo
(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> f, boolean stopOnComplete, boolean stopOnError, Scheduler scheduler) OnSubscribeReduce
(Observable<T> source, Func2<T, T, T> reducer) OnSubscribeReduceSeed
(Observable<T> source, R initialValue, Func2<R, ? super T, R> reducer) OnSubscribeSingle
(Observable<T> observable) OnSubscribeTakeLastOne
(Observable<T> source) OperatorBufferWithSingleObservable
(Observable<? extends TClosing> bufferClosing, int initialCapacity) OperatorBufferWithStartEndObservable
(Observable<? extends TOpening> bufferOpenings, Func1<? super TOpening, ? extends Observable<? extends TClosing>> bufferClosingSelector) OperatorDelayWithSelector
(Observable<? extends T> source, Func1<? super T, ? extends Observable<V>> itemDelay) private
OperatorMulticast
(Object guard, AtomicReference<Subject<? super T, ? extends R>> connectedSubject, List<Subscriber<? super R>> waitingForConnect, Observable<? extends T> source, Func0<? extends Subject<? super T, ? extends R>> subjectFactory) OperatorMulticast
(Observable<? extends T> source, Func0<? extends Subject<? super T, ? extends R>> subjectFactory) private
OperatorPublish
(Observable.OnSubscribe<T> onSubscribe, Observable<? extends T> source, AtomicReference<OperatorPublish.PublishSubscriber<T>> current) private
OperatorReplay
(Observable.OnSubscribe<T> onSubscribe, Observable<? extends T> source, AtomicReference<OperatorReplay.ReplaySubscriber<T>> current, Func0<? extends OperatorReplay.ReplayBuffer<T>> bufferFactory) OperatorSampleWithObservable
(Observable<U> sampler) OperatorSkipUntil
(Observable<U> other) OperatorSubscribeOn
(Observable<T> source, Scheduler scheduler) OperatorSwitchIfEmpty
(Observable<? extends T> alternate) OperatorTakeUntil
(Observable<? extends E> other) OperatorTimeout
(long timeout, TimeUnit timeUnit, Observable<? extends T> other, Scheduler scheduler) (package private)
OperatorTimeoutBase
(OperatorTimeoutBase.FirstTimeoutStub<T> firstTimeoutStub, OperatorTimeoutBase.TimeoutStub<T> timeoutStub, Observable<? extends T> other, Scheduler scheduler) OperatorTimeoutWithSelector
(Func0<? extends Observable<U>> firstTimeoutSelector, Func1<? super T, ? extends Observable<V>> timeoutSelector, Observable<? extends T> other) OperatorWindowWithObservable
(Observable<U> other) OperatorWindowWithStartEndObservable
(Observable<? extends U> windowOpenings, Func1<? super U, ? extends Observable<? extends V>> windowClosingSelector) OperatorWithLatestFrom
(Observable<? extends U> other, Func2<? super T, ? super U, ? extends R> resultSelector) OperatorWithLatestFromMany
(Observable<T> main, Observable<?>[] others, Iterable<Observable<?>> othersIterable, FuncN<R> combiner) (package private)
ParentSubscriber
(Subscriber<? super T> child, SerialSubscription ssub, ProducerArbiter arbiter, Observable<? extends T> alternate) SerializedSubject
(Observer<T> consumer, Observable<T> producer) SingleOnSubscribeDelaySubscriptionOther
(Single<? extends T> main, Observable<?> other) State
(Observer<T> consumer, Observable<T> producer, int count) (package private)
TimeoutSubscriber
(SerializedSubscriber<T> serializedSubscriber, OperatorTimeoutBase.TimeoutStub<T> timeoutStub, SerialSubscription serial, Observable<? extends T> other, Scheduler.Worker inner) WindowObservableFunc
(Observable<T> underlying, RefCountSubscription refCount) Constructor parameters in rx.internal.operators with type arguments of type ObservableModifierConstructorDescriptionConcatMapSubscriber
(Subscriber<? super R> actual, Func1<? super T, ? extends Observable<? extends R>> mapper, int prefetch, int delayErrorMode) EagerOuterSubscriber
(Func1<? super T, ? extends Observable<? extends R>> mapper, int bufferSize, int maxConcurrent, Subscriber<? super R> actual) ExactSubscriber
(Subscriber<? super Observable<T>> child, Scheduler.Worker worker) InexactSubscriber
(Subscriber<? super Observable<T>> child, Scheduler.Worker worker) MapPairSubscriber
(Subscriber<? super Observable<? extends R>> actual, Func1<? super T, ? extends Observable<? extends U>> collectionSelector, Func2<? super T, ? super U, ? extends R> resultSelector) MapPairSubscriber
(Subscriber<? super Observable<? extends R>> actual, Func1<? super T, ? extends Observable<? extends U>> collectionSelector, Func2<? super T, ? super U, ? extends R> resultSelector) private
OnSubscribeAmb
(Iterable<? extends Observable<? extends T>> sources) OnSubscribeCombineLatest
(Iterable<? extends Observable<? extends T>> sourcesIterable, FuncN<? extends R> combiner) OnSubscribeCombineLatest
(Observable<? extends T>[] sources, Iterable<? extends Observable<? extends T>> sourcesIterable, FuncN<? extends R> combiner, int bufferSize, boolean delayError) OnSubscribeConcatMap
(Observable<? extends T> source, Func1<? super T, ? extends Observable<? extends R>> mapper, int prefetch, int delayErrorMode) OnSubscribeDefer
(Func0<? extends Observable<? extends T>> observableFactory) OnSubscribeDelaySubscriptionWithSelector
(Observable<? extends T> source, Func0<? extends Observable<U>> subscriptionDelay) OnSubscribeGroupJoin
(Observable<T1> left, Observable<T2> right, Func1<? super T1, ? extends Observable<D1>> leftDuration, Func1<? super T2, ? extends Observable<D2>> rightDuration, Func2<? super T1, ? super Observable<T2>, ? extends R> resultSelector) OnSubscribeGroupJoin
(Observable<T1> left, Observable<T2> right, Func1<? super T1, ? extends Observable<D1>> leftDuration, Func1<? super T2, ? extends Observable<D2>> rightDuration, Func2<? super T1, ? super Observable<T2>, ? extends R> resultSelector) OnSubscribeJoin
(Observable<TLeft> left, Observable<TRight> right, Func1<TLeft, Observable<TLeftDuration>> leftDurationSelector, Func1<TRight, Observable<TRightDuration>> rightDurationSelector, Func2<TLeft, TRight, R> resultSelector) private
OnSubscribeRedo
(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> f, boolean stopOnComplete, boolean stopOnError, Scheduler scheduler) private
OnSubscribeRedo
(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> f, boolean stopOnComplete, boolean stopOnError, Scheduler scheduler) OnSubscribeUsing
(Func0<Resource> resourceFactory, Func1<? super Resource, ? extends Observable<? extends T>> observableFactory, Action1<? super Resource> dispose, boolean disposeEagerly) OperatorBufferWithSingleObservable
(Func0<? extends Observable<? extends TClosing>> bufferClosingSelector, int initialCapacity) OperatorBufferWithStartEndObservable
(Observable<? extends TOpening> bufferOpenings, Func1<? super TOpening, ? extends Observable<? extends TClosing>> bufferClosingSelector) OperatorDebounceWithSelector
(Func1<? super T, ? extends Observable<U>> selector) OperatorDelayWithSelector
(Observable<? extends T> source, Func1<? super T, ? extends Observable<V>> itemDelay) OperatorEagerConcatMap
(Func1<? super T, ? extends Observable<? extends R>> mapper, int bufferSize, int maxConcurrent) OperatorMapPair
(Func1<? super T, ? extends Observable<? extends U>> collectionSelector, Func2<? super T, ? super U, ? extends R> resultSelector) OperatorOnErrorResumeNextViaFunction
(Func1<Throwable, ? extends Observable<? extends T>> f) OperatorTimeoutWithSelector
(Func0<? extends Observable<U>> firstTimeoutSelector, Func1<? super T, ? extends Observable<V>> timeoutSelector, Observable<? extends T> other) OperatorTimeoutWithSelector
(Func0<? extends Observable<U>> firstTimeoutSelector, Func1<? super T, ? extends Observable<V>> timeoutSelector, Observable<? extends T> other) OperatorWindowWithObservableFactory
(Func0<? extends Observable<? extends U>> otherFactory) OperatorWindowWithStartEndObservable
(Observable<? extends U> windowOpenings, Func1<? super U, ? extends Observable<? extends V>> windowClosingSelector) OperatorWithLatestFromMany
(Observable<T> main, Observable<?>[] others, Iterable<Observable<?>> othersIterable, FuncN<R> combiner) SourceSubscriber
(Subscriber<? super Observable<T>> child) SourceSubscriber
(Subscriber<? super Observable<T>> child, Func0<? extends Observable<? extends U>> otherFactory) SourceSubscriber
(Subscriber<? super Observable<T>> child, Func0<? extends Observable<? extends U>> otherFactory) SourceSubscriber
(Subscriber<? super Observable<T>> child, CompositeSubscription csub) WindowExact
(Subscriber<? super Observable<T>> actual, int size) WindowOverlap
(Subscriber<? super Observable<T>> actual, int size, int skip) WindowSkip
(Subscriber<? super Observable<T>> actual, int size, int skip) -
Uses of Observable in rx.internal.schedulers
Fields in rx.internal.schedulers with type parameters of type ObservableModifier and TypeFieldDescriptionprivate final Observer
<Observable<Completable>> SchedulerWhen.workerObserver
Constructor parameters in rx.internal.schedulers with type arguments of type ObservableModifierConstructorDescriptionSchedulerWhen
(Func1<Observable<Observable<Completable>>, Completable> combine, Scheduler actualScheduler) SchedulerWhen
(Func1<Observable<Observable<Completable>>, Completable> combine, Scheduler actualScheduler) -
Uses of Observable in rx.internal.util
Subclasses of Observable in rx.internal.utilModifier and TypeClassDescriptionfinal class
An Observable that emits a single constant scalar value to Subscribers.Fields in rx.internal.util declared as ObservableModifier and TypeFieldDescriptionprivate final Observable
<T> InternalObservableUtils.ReplaySupplierBuffer.source
private final Observable
<T> InternalObservableUtils.ReplaySupplierBufferTime.source
private final Observable
<T> InternalObservableUtils.ReplaySupplierNoParams.source
private final Observable
<T> InternalObservableUtils.ReplaySupplierTime.source
Fields in rx.internal.util with type parameters of type ObservableModifier and TypeFieldDescription(package private) final Func1
<? super Observable<? extends Void>, ? extends Observable<?>> InternalObservableUtils.RepeatNotificationDematerializer.notificationHandler
(package private) final Func1
<? super Observable<? extends Void>, ? extends Observable<?>> InternalObservableUtils.RepeatNotificationDematerializer.notificationHandler
(package private) final Func1
<? super Observable<? extends Throwable>, ? extends Observable<?>> InternalObservableUtils.RetryNotificationDematerializer.notificationHandler
(package private) final Func1
<? super Observable<? extends Throwable>, ? extends Observable<?>> InternalObservableUtils.RetryNotificationDematerializer.notificationHandler
(package private) final Func1
<? super Observable<T>, ? extends Observable<R>> InternalObservableUtils.SelectorAndObserveOn.selector
(package private) final Func1
<? super Observable<T>, ? extends Observable<R>> InternalObservableUtils.SelectorAndObserveOn.selector
Methods in rx.internal.util that return ObservableModifier and TypeMethodDescriptionObservable
<?> InternalObservableUtils.RepeatNotificationDematerializer.call
(Observable<? extends Notification<?>> notifications) Observable
<?> InternalObservableUtils.RetryNotificationDematerializer.call
(Observable<? extends Notification<?>> notifications) InternalObservableUtils.SelectorAndObserveOn.call
(Observable<T> t) Observable<?>[]
InternalObservableUtils.ToArrayFunc1.call
(List<? extends Observable<?>> o) <R> Observable
<R> ScalarSynchronousObservable.scalarFlatMap
(Func1<? super T, ? extends Observable<? extends R>> func) Given this scalar source as input to a flatMap, avoid one step of subscription and subscribes to the single Observable returned by the function.ScalarSynchronousObservable.scalarScheduleOn
(Scheduler scheduler) Customized observeOn/subscribeOn implementation which emits the scalar value directly or with less overhead on the specified scheduler.Methods in rx.internal.util that return types with arguments of type ObservableModifier and TypeMethodDescriptionstatic final Func1
<Observable<? extends Notification<?>>, Observable<?>> InternalObservableUtils.createRepeatDematerializer
(Func1<? super Observable<? extends Void>, ? extends Observable<?>> notificationHandler) Returns a function that dematerializes the notification signal from an Observable and calls a notification handler with a null for non-terminal events.static final Func1
<Observable<? extends Notification<?>>, Observable<?>> InternalObservableUtils.createRepeatDematerializer
(Func1<? super Observable<? extends Void>, ? extends Observable<?>> notificationHandler) Returns a function that dematerializes the notification signal from an Observable and calls a notification handler with a null for non-terminal events.static <T,
R> Func1 <Observable<T>, Observable<R>> InternalObservableUtils.createReplaySelectorAndObserveOn
(Func1<? super Observable<T>, ? extends Observable<R>> selector, Scheduler scheduler) Creates a Func1 which calls the selector function with the received argument, applies an observeOn on the result and returns the resulting Observable.static <T,
R> Func1 <Observable<T>, Observable<R>> InternalObservableUtils.createReplaySelectorAndObserveOn
(Func1<? super Observable<T>, ? extends Observable<R>> selector, Scheduler scheduler) Creates a Func1 which calls the selector function with the received argument, applies an observeOn on the result and returns the resulting Observable.static final Func1
<Observable<? extends Notification<?>>, Observable<?>> InternalObservableUtils.createRetryDematerializer
(Func1<? super Observable<? extends Throwable>, ? extends Observable<?>> notificationHandler) Returns a function that dematerializes the notification signal from an Observable and calls a notification handler with the Throwable.static final Func1
<Observable<? extends Notification<?>>, Observable<?>> InternalObservableUtils.createRetryDematerializer
(Func1<? super Observable<? extends Throwable>, ? extends Observable<?>> notificationHandler) Returns a function that dematerializes the notification signal from an Observable and calls a notification handler with the Throwable.Methods in rx.internal.util with parameters of type ObservableModifier and TypeMethodDescriptionObservable
<?> InternalObservableUtils.RepeatNotificationDematerializer.call
(Observable<? extends Notification<?>> notifications) Observable
<?> InternalObservableUtils.RetryNotificationDematerializer.call
(Observable<? extends Notification<?>> notifications) InternalObservableUtils.SelectorAndObserveOn.call
(Observable<T> t) static <T> Func0
<ConnectableObservable<T>> InternalObservableUtils.createReplaySupplier
(Observable<T> source) Returns a Func0 that supplies the ConnectableObservable returned by calling replay() on the source.static <T> Func0
<ConnectableObservable<T>> InternalObservableUtils.createReplaySupplier
(Observable<T> source, int bufferSize) Returns a Func0 that supplies the ConnectableObservable returned by calling a parameterized replay() on the source.static <T> Func0
<ConnectableObservable<T>> InternalObservableUtils.createReplaySupplier
(Observable<T> source, int bufferSize, long time, TimeUnit unit, Scheduler scheduler) Returns a Func0 that supplies the ConnectableObservable returned by calling a parameterized replay() on the source.static <T> Func0
<ConnectableObservable<T>> InternalObservableUtils.createReplaySupplier
(Observable<T> source, long time, TimeUnit unit, Scheduler scheduler) Returns a Func0 that supplies the ConnectableObservable returned by calling a parameterized replay() on the source.Method parameters in rx.internal.util with type arguments of type ObservableModifier and TypeMethodDescriptionObservable<?>[]
InternalObservableUtils.ToArrayFunc1.call
(List<? extends Observable<?>> o) static final Func1
<Observable<? extends Notification<?>>, Observable<?>> InternalObservableUtils.createRepeatDematerializer
(Func1<? super Observable<? extends Void>, ? extends Observable<?>> notificationHandler) Returns a function that dematerializes the notification signal from an Observable and calls a notification handler with a null for non-terminal events.static final Func1
<Observable<? extends Notification<?>>, Observable<?>> InternalObservableUtils.createRepeatDematerializer
(Func1<? super Observable<? extends Void>, ? extends Observable<?>> notificationHandler) Returns a function that dematerializes the notification signal from an Observable and calls a notification handler with a null for non-terminal events.static <T,
R> Func1 <Observable<T>, Observable<R>> InternalObservableUtils.createReplaySelectorAndObserveOn
(Func1<? super Observable<T>, ? extends Observable<R>> selector, Scheduler scheduler) Creates a Func1 which calls the selector function with the received argument, applies an observeOn on the result and returns the resulting Observable.static <T,
R> Func1 <Observable<T>, Observable<R>> InternalObservableUtils.createReplaySelectorAndObserveOn
(Func1<? super Observable<T>, ? extends Observable<R>> selector, Scheduler scheduler) Creates a Func1 which calls the selector function with the received argument, applies an observeOn on the result and returns the resulting Observable.static final Func1
<Observable<? extends Notification<?>>, Observable<?>> InternalObservableUtils.createRetryDematerializer
(Func1<? super Observable<? extends Throwable>, ? extends Observable<?>> notificationHandler) Returns a function that dematerializes the notification signal from an Observable and calls a notification handler with the Throwable.static final Func1
<Observable<? extends Notification<?>>, Observable<?>> InternalObservableUtils.createRetryDematerializer
(Func1<? super Observable<? extends Throwable>, ? extends Observable<?>> notificationHandler) Returns a function that dematerializes the notification signal from an Observable and calls a notification handler with the Throwable.<R> Observable
<R> ScalarSynchronousObservable.scalarFlatMap
(Func1<? super T, ? extends Observable<? extends R>> func) Given this scalar source as input to a flatMap, avoid one step of subscription and subscribes to the single Observable returned by the function.Constructors in rx.internal.util with parameters of type ObservableModifierConstructorDescriptionprivate
ReplaySupplierBuffer
(Observable<T> source, int bufferSize) private
ReplaySupplierBufferTime
(Observable<T> source, long time, TimeUnit unit, Scheduler scheduler) private
ReplaySupplierNoParams
(Observable<T> source) private
ReplaySupplierTime
(Observable<T> source, int bufferSize, long time, TimeUnit unit, Scheduler scheduler) Constructor parameters in rx.internal.util with type arguments of type ObservableModifierConstructorDescriptionRepeatNotificationDematerializer
(Func1<? super Observable<? extends Void>, ? extends Observable<?>> notificationHandler) RepeatNotificationDematerializer
(Func1<? super Observable<? extends Void>, ? extends Observable<?>> notificationHandler) RetryNotificationDematerializer
(Func1<? super Observable<? extends Throwable>, ? extends Observable<?>> notificationHandler) RetryNotificationDematerializer
(Func1<? super Observable<? extends Throwable>, ? extends Observable<?>> notificationHandler) SelectorAndObserveOn
(Func1<? super Observable<T>, ? extends Observable<R>> selector, Scheduler scheduler) SelectorAndObserveOn
(Func1<? super Observable<T>, ? extends Observable<R>> selector, Scheduler scheduler) -
Uses of Observable in rx.observables
Subclasses of Observable in rx.observablesModifier and TypeClassDescription(package private) static final class
class
AConnectableObservable
resembles an ordinaryObservable
, except that it does not begin emitting items when it is subscribed to, but only when itsConnectableObservable.connect()
method is called.class
GroupedObservable<K,
T> AnObservable
that has been grouped by key, the value of which can be obtained withGroupedObservable.getKey()
.Fields in rx.observables declared as ObservableFields in rx.observables with type parameters of type ObservableModifier and TypeFieldDescriptionprivate final AsyncOnSubscribe.UnicastSubject
<Observable<T>> AsyncOnSubscribe.AsyncOuterManager.merger
AsyncOnSubscribe.AsyncOnSubscribeImpl.next
private final SerializedObserver
<Observable<? extends T>> AsyncOnSubscribe.AsyncOuterManager.serializedSubscriber
Methods in rx.observables that return ObservableModifier and TypeMethodDescriptionConnectableObservable.autoConnect()
Returns an Observable that automatically connects to this ConnectableObservable when the first Subscriber subscribes.ConnectableObservable.autoConnect
(int numberOfSubscribers) Returns an Observable that automatically connects to this ConnectableObservable when the specified number of Subscribers subscribe to it.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.ConnectableObservable.refCount()
Returns anObservable
that stays connected to thisConnectableObservable
as long as there is at least one subscription to thisConnectableObservable
.Methods in rx.observables with parameters of type ObservableModifier and TypeMethodDescriptionprivate T
BlockingObservable.blockForSingle
(Observable<? extends T> observable) Helper method which handles the actual blocking for a single response.static <T> BlockingObservable
<T> BlockingObservable.from
(Observable<? extends T> o) Converts anObservable
into aBlockingObservable
.static <K,
T> GroupedObservable <K, T> GroupedObservable.from
(K key, Observable<T> o) Converts anObservable
into aGroupedObservable
with a particular key.void
AsyncOnSubscribe.AsyncOuterManager.onNext
(Observable<? extends T> t) private void
AsyncOnSubscribe.AsyncOuterManager.subscribeBufferToObservable
(Observable<? extends T> t) Method parameters in rx.observables with type arguments of type ObservableModifier and TypeMethodDescriptionstatic <S,
T> AsyncOnSubscribe <S, T> AsyncOnSubscribe.createSingleState
(Func0<? extends S> generator, Action3<? super S, Long, ? super Observer<Observable<? extends T>>> next) Generates a synchronousAsyncOnSubscribe
that calls the providednext
function to generate data to downstream subscribers.static <S,
T> AsyncOnSubscribe <S, T> AsyncOnSubscribe.createSingleState
(Func0<? extends S> generator, Action3<? super S, Long, ? super Observer<Observable<? extends T>>> next, Action1<? super S> onUnsubscribe) Generates a synchronousAsyncOnSubscribe
that calls the providednext
function to generate data to downstream subscribers.static <S,
T> AsyncOnSubscribe <S, T> AsyncOnSubscribe.createStateful
(Func0<? extends S> generator, Func3<? super S, Long, ? super Observer<Observable<? extends T>>, ? extends S> next) Generates a synchronousAsyncOnSubscribe
that calls the providednext
function to generate data to downstream subscribers.static <S,
T> AsyncOnSubscribe <S, T> AsyncOnSubscribe.createStateful
(Func0<? extends S> generator, Func3<? super S, Long, ? super Observer<Observable<? extends T>>, ? extends S> next, Action1<? super S> onUnsubscribe) Generates a synchronousAsyncOnSubscribe
that calls the providednext
function to generate data to downstream subscribers.static <T> AsyncOnSubscribe
<Void, T> AsyncOnSubscribe.createStateless
(Action2<Long, ? super Observer<Observable<? extends T>>> next) Generates a synchronousAsyncOnSubscribe
that calls the providednext
function to generate data to downstream subscribers.static <T> AsyncOnSubscribe
<Void, T> AsyncOnSubscribe.createStateless
(Action2<Long, ? super Observer<Observable<? extends T>>> next, Action0 onUnsubscribe) Generates a synchronousAsyncOnSubscribe
that calls the providednext
function to generate data to downstream subscribers.protected S
AsyncOnSubscribe.AsyncOnSubscribeImpl.next
(S state, long requested, Observer<Observable<? extends T>> observer) protected abstract S
AsyncOnSubscribe.next
(S state, long requested, Observer<Observable<? extends T>> observer) Called to produce data to the downstream subscribers.Constructors in rx.observables with parameters of type ObservableConstructor parameters in rx.observables with type arguments of type ObservableModifierConstructorDescriptionAsyncOnSubscribeImpl
(Func0<? extends S> generator, Func3<? super S, Long, ? super Observer<Observable<? extends T>>, ? extends S> next) (package private)
AsyncOnSubscribeImpl
(Func0<? extends S> generator, Func3<? super S, Long, ? super Observer<Observable<? extends T>>, ? extends S> next, Action1<? super S> onUnsubscribe) AsyncOnSubscribeImpl
(Func3<S, Long, Observer<Observable<? extends T>>, S> nextFunc) AsyncOnSubscribeImpl
(Func3<S, Long, Observer<Observable<? extends T>>, S> next, Action1<? super S> onUnsubscribe) AsyncOuterManager
(AsyncOnSubscribe<S, T> parent, S initialState, AsyncOnSubscribe.UnicastSubject<Observable<T>> merger) -
Uses of Observable in rx.plugins
Fields in rx.plugins with type parameters of type ObservableModifier and TypeFieldDescription(package private) static Func2
<Observable, Observable.OnSubscribe, Observable.OnSubscribe> RxJavaHooks.onObservableStart
Methods in rx.plugins that return types with arguments of type ObservableModifier and TypeMethodDescriptionRxJavaHooks.getOnObservableStart()
Returns the current Observable onStart hook function or null if it is set to the default pass-through.Methods in rx.plugins with parameters of type ObservableModifier and TypeMethodDescriptionstatic <T> Observable.OnSubscribe
<T> RxJavaHooks.onObservableStart
(Observable<T> instance, Observable.OnSubscribe<T> onSubscribe) Hook to call before the child subscriber is subscribed to the OnSubscribe action.<T> Observable.OnSubscribe
<T> RxJavaObservableExecutionHook.onSubscribeStart
(Observable<? extends T> observableInstance, Observable.OnSubscribe<T> onSubscribe) Deprecated.Method parameters in rx.plugins with type arguments of type ObservableModifier and TypeMethodDescriptionstatic void
RxJavaHooks.setOnObservableStart
(Func2<Observable, Observable.OnSubscribe, Observable.OnSubscribe> onObservableStart) Sets the hook function that is called when a subscriber subscribes to a Observable unless a lockdown is in effect. -
Uses of Observable in rx.subjects
Subclasses of Observable in rx.subjectsModifier and TypeClassDescriptionfinal class
AsyncSubject<T>
Subject that publishes only the last item observed to eachObserver
once the sourceObservable
has completed.final class
Subject that emits the most recent item it has observed and all subsequent observed items to each subscribedObserver
.final class
Subject that, once anObserver
has subscribed, emits all subsequently observed items to the subscriber.final class
Subject that buffers all items it observes and replays them to anyObserver
that subscribes.class
SerializedSubject<T,
R> Wraps aSubject
so that it is safe to call its variouson
methods from different threads.class
Subject<T,
R> Represents an object that is both an Observable and an Observer.final class
TestSubject<T>
A variety of Subject that is useful for testing purposes.final class
A Subject variant which buffers events until a single Subscriber arrives and replays them to it and potentially switches to direct delivery once the Subscriber caught up and requested an unlimited amount.
cacheWithInitialCapacity(int)
instead.