static <T> Observable<T> |
Observable.concatDelayError(java.lang.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(java.lang.Iterable<? extends Observable<? extends T>> sources) |
Concatenates a sequence of Observables eagerly into a single stream of values.
|
static <T> Observable<T> |
Observable.concatEager(java.lang.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.
|
<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.
|
<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.
|
<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.
|
<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.
|
static <S,T> Observable<T> |
Observable.create(AsyncOnSubscribe<S,T> asyncOnSubscribe) |
Returns an Observable that respects the back-pressure semantics.
|
static <T> Single<T> |
Single.defer(java.util.concurrent.Callable<Single<T>> singleFactory) |
Returns a Single that calls a Single factory to create a Single for each new Observer
that subscribes.
|
Single<T> |
Single.delay(long delay,
java.util.concurrent.TimeUnit unit) |
Returns an Single that emits the items emitted by the source Single shifted forward in time by a
specified delay.
|
Single<T> |
Single.delay(long delay,
java.util.concurrent.TimeUnit unit,
Scheduler scheduler) |
Returns an Single that emits the items emitted by the source Single shifted forward in time by a
specified delay.
|
<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<T> |
Single.delaySubscription(Observable<?> other) |
Returns a Single that delays the subscription to this Single
until the Observable completes.
|
Observable<T> |
Observable.distinctUntilChanged(Func2<? super T,? super T,java.lang.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.
|
Single<T> |
Single.doAfterTerminate(Action0 action) |
|
Single<T> |
Single.doOnError(Action1<java.lang.Throwable> onError) |
Modifies the source Single so that it invokes an action if it calls onError .
|
Single<T> |
Single.doOnSubscribe(Action0 subscribe) |
Modifies the source Single so that it invokes the given action when it is subscribed from
its subscribers.
|
Single<T> |
Single.doOnSuccess(Action1<? super T> onSuccess) |
Modifies the source Single so that it invokes an action when it calls onSuccess .
|
Single<T> |
Single.doOnUnsubscribe(Action0 action) |
Modifies the source Single so that it invokes the given action when it is unsubscribed from
its subscribers.
|
<R> R |
Observable.extend(Func1<? super Observable.OnSubscribe<T>,? extends R> conversion) |
Passes all emitted values from this Observable to the provided conversion function to be collected and
returned as a single value.
|
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.
|
<K,R> Observable<GroupedObservable<K,R>> |
Observable.groupBy(Func1<? super T,? extends K> keySelector,
Func1<? super T,? extends R> elementSelector,
Func1<Action1<K>,java.util.Map<K,java.lang.Object>> evictingMapFactory) |
Groups the items emitted by an Observable according to a specified criterion, and emits these
grouped items as GroupedObservable s.
|
<R> Single<R> |
Single.lift(Observable.Operator<? extends R,? super T> lift) |
Lifts a function to the current Single and returns a new Single that when subscribed to will pass the
values of the current Single through the Operator function.
|
static <T> Observable<T> |
Observable.mergeDelayError(Observable<? extends Observable<? extends T>> source,
int maxConcurrent) |
Flattens an Observable that emits Observables into one Observable, in a way that allows an Observer to
receive all successfully emitted items from all of the source Observables without being interrupted by
an error notification from one of them, while limiting the
number of concurrent subscriptions to these Observables.
|
Observable<T> |
Observable.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.
|
Single<T> |
Single.onErrorResumeNext(Func1<java.lang.Throwable,? extends Single<? extends T>> resumeFunctionInCaseOfError) |
|
Single<T> |
Single.onErrorResumeNext(Single<? extends T> resumeSingleInCaseOfError) |
|
Observable<T> |
Observable.onTerminateDetach() |
Nulls out references to the upstream producer and downstream Subscriber if
the sequence is terminated or downstream unsubscribes.
|
Observable<T> |
Observable.rebatchRequests(int n) |
Requests n initially from the upstream and then 75% of n subsequently
after 75% of n values have been emitted to the downstream.
|
<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.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.
|
BlockingSingle<T> |
Single.toBlocking() |
Converts a Single into a BlockingSingle (a Single with blocking operators).
|
Completable |
Observable.toCompletable() |
Returns a Completable that discards all onNext emissions (similar to
ignoreAllElements() ) and calls onCompleted when this source observable calls
onCompleted.
|
Completable |
Single.toCompletable() |
|
Observable<java.util.List<T>> |
Observable.toSortedList(int initialCapacity) |
Returns an Observable that emits a list that contains the items emitted by the source Observable, in a
sorted order.
|
Observable<java.util.List<T>> |
Observable.toSortedList(Func2<? super T,? super T,java.lang.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.
|
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 set disposeEagerly to true and unsubscription does not occur
before termination.
|
static <T,Resource> Single<T> |
Single.using(Func0<Resource> resourceFactory,
Func1<? super Resource,? extends Single<? extends T>> singleFactory,
Action1<? super Resource> disposeAction) |
Constructs an Single that creates a dependent resource object which is disposed of on unsubscription.
|
static <T,Resource> Single<T> |
Single.using(Func0<Resource> resourceFactory,
Func1<? super Resource,? extends Single<? extends T>> singleFactory,
Action1<? super Resource> disposeAction,
boolean disposeEagerly) |
Constructs an Single that creates a dependent resource object which is disposed of just before
termination if you have set disposeEagerly to true and unsubscription does not occur
before termination.
|
<S extends Scheduler & Subscription> S |
Scheduler.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.
|
<R> Observable<R> |
Observable.withLatestFrom(java.lang.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.
|
<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.
|
<U,R> Observable<R> |
Observable.withLatestFrom(Observable<? extends U> other,
Func2<? super T,? super U,? extends R> resultSelector) |
Merges the specified Observable into this Observable sequence by using the resultSelector
function only when the source Observable (this instance) emits an item.
|
<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.
|
<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.
|
<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.
|
<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.
|
<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.
|
<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.
|
<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.
|