Package | Description |
---|---|
rx |
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
|
rx.internal.operators |
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
|
rx.internal.util | |
rx.plugins |
Callback types and a central plugin handler class to hook into the lifecycle
of the base reactive types and schedulers.
|
rx.singles |
Classes extending the Single base reactive class.
|
Modifier and Type | Method and Description |
---|---|
<T> Single<T> |
Completable.andThen(Single<T> next)
Returns a Single which will subscribe to this Completable and once that is completed then
will subscribe to the
next Single. |
Single<T> |
Single.cache()
Returns a Single that subscribes to this Single lazily, caches its success or error event
and replays it to all the downstream subscribers.
|
<R> Single<R> |
Single.compose(Single.Transformer<? super T,? extends R> transformer)
Transform a Single by applying a particular Transformer function to it.
|
static <T> Single<T> |
Single.create(Single.OnSubscribe<T> f)
Returns a Single that will execute the specified function when a
SingleSubscriber executes it or
a Subscriber subscribes to it. |
static <T> Single<T> |
Single.defer(Callable<Single<T>> singleFactory)
|
Single<T> |
Single.delay(long delay,
TimeUnit unit)
Returns a Single that emits the items emitted by the source Single shifted forward in time by a
specified delay.
|
Single<T> |
Single.delay(long delay,
TimeUnit unit,
Scheduler scheduler)
Returns a Single that emits the items emitted by the source Single shifted forward in time by a
specified delay.
|
Single<T> |
Single.delaySubscription(Observable<?> other)
Returns a Single that delays the subscription to this Single
until the Observable completes.
|
Single<T> |
Single.doAfterTerminate(Action0 action)
Registers an
Action0 to be called when this Single invokes either
SingleSubscriber.onSuccess(Object) onSuccess} or onError . |
Single<T> |
Single.doOnEach(Action1<Notification<? extends T>> onNotification)
|
Single<T> |
Single.doOnError(Action1<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. |
static <T> Single<T> |
Single.error(Throwable exception)
Returns a Single that invokes a subscriber's
onError method when the
subscriber subscribes to it. |
<R> Single<R> |
Single.flatMap(Func1<? super T,? extends Single<? extends R>> func)
Returns a Single that is based on applying a specified function to the item emitted by the source Single,
where that function returns a Single.
|
static <T> Single<T> |
Single.from(Future<? extends T> future)
Converts a
Future into a Single . |
static <T> Single<T> |
Single.from(Future<? extends T> future,
long timeout,
TimeUnit unit)
Converts a
Future into a Single , with a timeout on the Future. |
static <T> Single<T> |
Single.from(Future<? extends T> future,
Scheduler scheduler)
|
static <T> Single<T> |
Single.fromCallable(Callable<? extends T> func)
Returns a
Single that invokes passed function and emits its result for each new Observer that subscribes. |
static <T> Single<T> |
Single.fromEmitter(Action1<SingleEmitter<T>> producer)
Provides an API (in a cold Single) that bridges the Single-reactive world
with the callback-based world.
|
static <T> Single<T> |
Single.just(T value)
Returns a
Single that emits a specified item. |
<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.
|
<R> Single<R> |
Single.map(Func1<? super T,? extends R> func)
Returns a Single that applies a specified function to the item emitted by the source Single and
emits the result of this function application.
|
static <T> Single<T> |
Single.merge(Single<? extends Single<? extends T>> source)
Flattens a
Single that emits a Single into a single Single that emits the item
emitted by the nested Single , without any transformation. |
Single<T> |
Single.observeOn(Scheduler scheduler)
Modifies a Single to emit its item (or notify of its error) on a specified
Scheduler ,
asynchronously. |
Single<T> |
Single.onErrorResumeNext(Func1<Throwable,? extends Single<? extends T>> resumeFunctionInCaseOfError)
Instructs a Single to pass control to another Single rather than invoking
Observer.onError(Throwable) if it encounters an error. |
Single<T> |
Single.onErrorResumeNext(Single<? extends T> resumeSingleInCaseOfError)
Instructs a Single to pass control to another Single rather than invoking
Observer.onError(Throwable) if it encounters an error. |
Single<T> |
Single.onErrorReturn(Func1<Throwable,? extends T> resumeFunction)
Instructs a Single to emit an item (returned by a specified function) rather than invoking
onError if it encounters an error. |
Single<T> |
Single.retry()
Returns a Single that mirrors the source Single, resubscribing to it if it calls
onError
(infinite retry count). |
Single<T> |
Single.retry(Func2<Integer,Throwable,Boolean> predicate)
Returns a Single that mirrors the source Single, resubscribing to it if it calls
onError
and the predicate returns true for that specific exception and retry count. |
Single<T> |
Single.retry(long count)
Returns a Single that mirrors the source Single, resubscribing to it if it calls
onError
up to a specified number of retries. |
Single<T> |
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 an
onError . |
Single<T> |
Single.subscribeOn(Scheduler scheduler)
Asynchronously subscribes subscribers to this Single on the specified
Scheduler . |
Single<T> |
Single.takeUntil(Completable other)
Returns a Single that emits the item emitted by the source Single until a Completable terminates.
|
<E> Single<T> |
Single.takeUntil(Observable<? extends E> other)
Returns a Single that emits the item emitted by the source Single until an Observable emits an item.
|
<E> Single<T> |
Single.takeUntil(Single<? extends E> other)
Returns a Single that emits the item emitted by the source Single until a second Single emits an item.
|
Single<T> |
Single.timeout(long timeout,
TimeUnit timeUnit)
Returns a Single that mirrors the source Single but applies a timeout policy for its emitted item.
|
Single<T> |
Single.timeout(long timeout,
TimeUnit timeUnit,
Scheduler scheduler)
Returns a Single that mirrors the source Single but applies a timeout policy for its emitted item, where
this policy is governed on a specified Scheduler.
|
Single<T> |
Single.timeout(long timeout,
TimeUnit timeUnit,
Single<? extends T> other)
Returns a Single that mirrors the source Single but applies a timeout policy for its emitted item.
|
Single<T> |
Single.timeout(long timeout,
TimeUnit timeUnit,
Single<? extends T> other,
Scheduler scheduler)
Returns a Single that mirrors the source Single but applies a timeout policy for its emitted item, using
a specified Scheduler.
|
Single<T> |
Observable.toSingle()
Returns a Single that emits the single item emitted by the source Observable, if that Observable
emits only a single item.
|
<T> Single<T> |
Completable.toSingle(Func0<? extends T> completionValueFunc0)
Converts this Completable into a Single which when this Completable completes normally,
calls the given supplier and emits its returned value through onSuccess.
|
<T> Single<T> |
Completable.toSingleDefault(T completionValue)
Converts this Completable into a Single which when this Completable completes normally,
emits the given value through onSuccess.
|
Single<T> |
Single.unsubscribeOn(Scheduler scheduler)
Returns a Single which makes sure when a subscriber cancels the subscription,
the dispose is called on the specified scheduler
|
static <T,Resource> |
Single.using(Func0<Resource> resourceFactory,
Func1<? super Resource,? extends Single<? extends T>> singleFactory,
Action1<? super Resource> disposeAction)
Constructs a Single that creates a dependent resource object which is disposed of on unsubscription.
|
static <T,Resource> |
Single.using(Func0<Resource> resourceFactory,
Func1<? super Resource,? extends Single<? extends T>> singleFactory,
Action1<? super Resource> disposeAction,
boolean disposeEagerly)
Constructs a 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. |
static <R> Single<R> |
Single.zip(Iterable<? extends Single<?>> singles,
FuncN<? extends R> zipFunction)
Returns a Single that emits the result of specified combiner function applied to combination of
items emitted, in sequence, by an Iterable of other Singles.
|
static <T1,T2,R> Single<R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Func2<? super T1,? super T2,? extends R> zipFunction)
Returns a Single that emits the results of a specified combiner function applied to two items emitted by
two other Singles.
|
static <T1,T2,T3,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Func3<? super T1,? super T2,? super T3,? extends R> zipFunction)
Returns a Single that emits the results of a specified combiner function applied to three items emitted
by three other Singles.
|
static <T1,T2,T3,T4,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
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 four items
emitted by four other Singles.
|
static <T1,T2,T3,T4,T5,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
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 five items
emitted by five other Singles.
|
static <T1,T2,T3,T4,T5,T6,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
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 six items
emitted by six other Singles.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
Single<? extends T7> s7,
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 seven items
emitted by seven other Singles.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
Single<? extends T7> s7,
Single<? extends T8> s8,
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 eight items
emitted by eight other Singles.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
Single<? extends T7> s7,
Single<? extends T8> s8,
Single<? extends T9> s9,
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 nine items
emitted by nine other Singles.
|
<T2,R> Single<R> |
Single.zipWith(Single<? extends T2> other,
Func2<? super T,? super T2,? extends R> zipFunction)
Returns a Single that emits the result of applying a specified function to the pair of items emitted by
the source Single and another specified Single.
|
Modifier and Type | Method and Description |
---|---|
<T> Single<T> |
Completable.andThen(Single<T> next)
Returns a Single which will subscribe to this Completable and once that is completed then
will subscribe to the
next Single. |
static <T> Observable<T> |
Single.concat(Single<? extends T> t1,
Single<? extends T> t2)
Returns an Observable that emits the items emitted by two Singles, one after the other.
|
static <T> Observable<T> |
Single.concat(Single<? extends T> t1,
Single<? extends T> t2)
Returns an Observable that emits the items emitted by two Singles, one after the other.
|
static <T> Observable<T> |
Single.concat(Single<? extends T> t1,
Single<? extends T> t2,
Single<? extends T> t3)
Returns an Observable that emits the items emitted by three Singles, one after the other.
|
static <T> Observable<T> |
Single.concat(Single<? extends T> t1,
Single<? extends T> t2,
Single<? extends T> t3)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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> |
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> |
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> |
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> |
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> |
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> |
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> |
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> |
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.
|
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.
|
static Completable |
Completable.fromSingle(Single<?> single)
Returns a Completable instance that when subscribed to, subscribes to the Single instance and
emits a completion event if the single emits onSuccess or forwards any onError events.
|
static <T> Single<T> |
Single.merge(Single<? extends Single<? extends T>> source)
Flattens a
Single that emits a Single into a single Single that emits the item
emitted by the nested Single , without any transformation. |
static <T> Observable<T> |
Single.merge(Single<? extends T> t1,
Single<? extends T> t2)
Flattens two Singles into a single Observable, without any transformation.
|
static <T> Observable<T> |
Single.merge(Single<? extends T> t1,
Single<? extends T> t2)
Flattens two Singles into a single Observable, without any transformation.
|
static <T> Observable<T> |
Single.merge(Single<? extends T> t1,
Single<? extends T> t2,
Single<? extends T> t3)
Flattens three Singles into a single Observable, without any transformation.
|
static <T> Observable<T> |
Single.merge(Single<? extends T> t1,
Single<? extends T> t2,
Single<? extends T> t3)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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> |
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> |
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> |
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> |
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> |
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> |
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> |
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> |
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.
|
Observable<T> |
Single.mergeWith(Single<? extends T> t1)
Flattens this and another Single into a single Observable, without any transformation.
|
Single<T> |
Single.onErrorResumeNext(Single<? extends T> resumeSingleInCaseOfError)
Instructs a Single to pass control to another Single rather than invoking
Observer.onError(Throwable) if it encounters an error. |
<E> Single<T> |
Single.takeUntil(Single<? extends E> other)
Returns a Single that emits the item emitted by the source Single until a second Single emits an item.
|
Single<T> |
Single.timeout(long timeout,
TimeUnit timeUnit,
Single<? extends T> other)
Returns a Single that mirrors the source Single but applies a timeout policy for its emitted item.
|
Single<T> |
Single.timeout(long timeout,
TimeUnit timeUnit,
Single<? extends T> other,
Scheduler scheduler)
Returns a Single that mirrors the source Single but applies a timeout policy for its emitted item, using
a specified Scheduler.
|
static <T1,T2,R> Single<R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Func2<? super T1,? super T2,? extends R> zipFunction)
Returns a Single that emits the results of a specified combiner function applied to two items emitted by
two other Singles.
|
static <T1,T2,R> Single<R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Func2<? super T1,? super T2,? extends R> zipFunction)
Returns a Single that emits the results of a specified combiner function applied to two items emitted by
two other Singles.
|
static <T1,T2,T3,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Func3<? super T1,? super T2,? super T3,? extends R> zipFunction)
Returns a Single that emits the results of a specified combiner function applied to three items emitted
by three other Singles.
|
static <T1,T2,T3,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Func3<? super T1,? super T2,? super T3,? extends R> zipFunction)
Returns a Single that emits the results of a specified combiner function applied to three items emitted
by three other Singles.
|
static <T1,T2,T3,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Func3<? super T1,? super T2,? super T3,? extends R> zipFunction)
Returns a Single that emits the results of a specified combiner function applied to three items emitted
by three other Singles.
|
static <T1,T2,T3,T4,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
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 four items
emitted by four other Singles.
|
static <T1,T2,T3,T4,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
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 four items
emitted by four other Singles.
|
static <T1,T2,T3,T4,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
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 four items
emitted by four other Singles.
|
static <T1,T2,T3,T4,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
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 four items
emitted by four other Singles.
|
static <T1,T2,T3,T4,T5,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
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 five items
emitted by five other Singles.
|
static <T1,T2,T3,T4,T5,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
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 five items
emitted by five other Singles.
|
static <T1,T2,T3,T4,T5,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
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 five items
emitted by five other Singles.
|
static <T1,T2,T3,T4,T5,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
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 five items
emitted by five other Singles.
|
static <T1,T2,T3,T4,T5,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
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 five items
emitted by five other Singles.
|
static <T1,T2,T3,T4,T5,T6,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
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 six items
emitted by six other Singles.
|
static <T1,T2,T3,T4,T5,T6,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
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 six items
emitted by six other Singles.
|
static <T1,T2,T3,T4,T5,T6,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
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 six items
emitted by six other Singles.
|
static <T1,T2,T3,T4,T5,T6,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
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 six items
emitted by six other Singles.
|
static <T1,T2,T3,T4,T5,T6,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
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 six items
emitted by six other Singles.
|
static <T1,T2,T3,T4,T5,T6,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
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 six items
emitted by six other Singles.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
Single<? extends T7> s7,
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 seven items
emitted by seven other Singles.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
Single<? extends T7> s7,
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 seven items
emitted by seven other Singles.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
Single<? extends T7> s7,
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 seven items
emitted by seven other Singles.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
Single<? extends T7> s7,
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 seven items
emitted by seven other Singles.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
Single<? extends T7> s7,
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 seven items
emitted by seven other Singles.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
Single<? extends T7> s7,
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 seven items
emitted by seven other Singles.
|
static <T1,T2,T3,T4,T5,T6,T7,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
Single<? extends T7> s7,
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 seven items
emitted by seven other Singles.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
Single<? extends T7> s7,
Single<? extends T8> s8,
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 eight items
emitted by eight other Singles.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
Single<? extends T7> s7,
Single<? extends T8> s8,
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 eight items
emitted by eight other Singles.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
Single<? extends T7> s7,
Single<? extends T8> s8,
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 eight items
emitted by eight other Singles.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
Single<? extends T7> s7,
Single<? extends T8> s8,
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 eight items
emitted by eight other Singles.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
Single<? extends T7> s7,
Single<? extends T8> s8,
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 eight items
emitted by eight other Singles.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
Single<? extends T7> s7,
Single<? extends T8> s8,
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 eight items
emitted by eight other Singles.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
Single<? extends T7> s7,
Single<? extends T8> s8,
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 eight items
emitted by eight other Singles.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
Single<? extends T7> s7,
Single<? extends T8> s8,
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 eight items
emitted by eight other Singles.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
Single<? extends T7> s7,
Single<? extends T8> s8,
Single<? extends T9> s9,
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 nine items
emitted by nine other Singles.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
Single<? extends T7> s7,
Single<? extends T8> s8,
Single<? extends T9> s9,
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 nine items
emitted by nine other Singles.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
Single<? extends T7> s7,
Single<? extends T8> s8,
Single<? extends T9> s9,
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 nine items
emitted by nine other Singles.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
Single<? extends T7> s7,
Single<? extends T8> s8,
Single<? extends T9> s9,
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 nine items
emitted by nine other Singles.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
Single<? extends T7> s7,
Single<? extends T8> s8,
Single<? extends T9> s9,
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 nine items
emitted by nine other Singles.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
Single<? extends T7> s7,
Single<? extends T8> s8,
Single<? extends T9> s9,
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 nine items
emitted by nine other Singles.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
Single<? extends T7> s7,
Single<? extends T8> s8,
Single<? extends T9> s9,
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 nine items
emitted by nine other Singles.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
Single<? extends T7> s7,
Single<? extends T8> s8,
Single<? extends T9> s9,
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 nine items
emitted by nine other Singles.
|
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Single<? extends T4> s4,
Single<? extends T5> s5,
Single<? extends T6> s6,
Single<? extends T7> s7,
Single<? extends T8> s8,
Single<? extends T9> s9,
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 nine items
emitted by nine other Singles.
|
<T2,R> Single<R> |
Single.zipWith(Single<? extends T2> other,
Func2<? super T,? super T2,? extends R> zipFunction)
Returns a Single that emits the result of applying a specified function to the pair of items emitted by
the source Single and another specified Single.
|
Modifier and Type | Method and Description |
---|---|
static <T> Single<T> |
Single.defer(Callable<Single<T>> singleFactory)
|
<R> Single<R> |
Single.flatMap(Func1<? super T,? extends Single<? extends R>> func)
Returns a Single that is based on applying a specified function to the item emitted by the source Single,
where that function returns a Single.
|
<R> Observable<R> |
Observable.flatMapSingle(Func1<? super T,? extends Single<? extends R>> mapper)
Maps all upstream values to Singles and runs them together until the upstream
and all inner Singles complete normally.
|
<R> Observable<R> |
Observable.flatMapSingle(Func1<? super T,? extends Single<? extends R>> mapper,
boolean delayErrors)
Maps all upstream values to Singles and runs them together, optionally delaying any errors, until the upstream
and all inner Singles terminate.
|
<R> Observable<R> |
Observable.flatMapSingle(Func1<? super T,? extends Single<? extends R>> mapper,
boolean delayErrors,
int maxConcurrency)
Maps upstream values to Singles and runs up to the given number of them together at a time,
optionally delaying any errors, until the upstream and all inner Singles terminate.
|
static <T> Observable<T> |
Single.merge(Observable<? extends Single<? extends T>> sources)
Merges all Singles emitted by the Observable and runs them together until the source
Observable and all inner Singles complete normally.
|
static <T> Observable<T> |
Single.merge(Observable<? extends Single<? extends T>> sources,
int maxConcurrency)
Merges the Singles emitted by the Observable and runs up to the given number of them together at a time,
until the Observable and all inner Singles terminate.
|
static <T> Single<T> |
Single.merge(Single<? extends Single<? extends T>> source)
Flattens a
Single that emits a Single into a single Single that emits the item
emitted by the nested Single , without any transformation. |
static <T> Observable<T> |
Single.mergeDelayError(Observable<? extends Single<? extends T>> sources)
Merges all Singles emitted by the Observable and runs them together,
delaying errors from them and the Observable, until the source
Observable and all inner Singles complete normally.
|
static <T> Observable<T> |
Single.mergeDelayError(Observable<? extends Single<? extends T>> sources,
int maxConcurrency)
Merges the Singles emitted by the Observable and runs up to the given number of them together at a time,
delaying errors from them and the Observable, until the Observable and all inner Singles terminate.
|
Single<T> |
Single.onErrorResumeNext(Func1<Throwable,? extends Single<? extends T>> resumeFunctionInCaseOfError)
Instructs a Single to pass control to another Single rather than invoking
Observer.onError(Throwable) if it encounters an error. |
<R> R |
Single.to(Func1<? super Single<T>,R> converter)
Calls the specified converter function during assembly time and returns its resulting value.
|
static <T,Resource> |
Single.using(Func0<Resource> resourceFactory,
Func1<? super Resource,? extends Single<? extends T>> singleFactory,
Action1<? super Resource> disposeAction)
Constructs a Single that creates a dependent resource object which is disposed of on unsubscription.
|
static <T,Resource> |
Single.using(Func0<Resource> resourceFactory,
Func1<? super Resource,? extends Single<? extends T>> singleFactory,
Action1<? super Resource> disposeAction,
boolean disposeEagerly)
Constructs a 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. |
static <R> Single<R> |
Single.zip(Iterable<? extends Single<?>> singles,
FuncN<? extends R> zipFunction)
Returns a Single that emits the result of specified combiner function applied to combination of
items emitted, in sequence, by an Iterable of other Singles.
|
Modifier and Type | Method and Description |
---|---|
static <T,R> Single<R> |
SingleOperatorZip.zip(Single<? extends T>[] singles,
FuncN<? extends R> zipper) |
Modifier and Type | Method and Description |
---|---|
static <T> SingleOperatorOnErrorResumeNext<T> |
SingleOperatorOnErrorResumeNext.withFunction(Single<? extends T> originalSingle,
Func1<Throwable,? extends Single<? extends T>> resumeFunctionInCaseOfError) |
static <T> SingleOperatorOnErrorResumeNext<T> |
SingleOperatorOnErrorResumeNext.withOther(Single<? extends T> originalSingle,
Single<? extends T> resumeSingleInCaseOfError) |
static <T> SingleOperatorOnErrorResumeNext<T> |
SingleOperatorOnErrorResumeNext.withOther(Single<? extends T> originalSingle,
Single<? extends T> resumeSingleInCaseOfError) |
static <T,R> Single<R> |
SingleOperatorZip.zip(Single<? extends T>[] singles,
FuncN<? extends R> zipper) |
Modifier and Type | Method and Description |
---|---|
static <T> SingleOperatorOnErrorResumeNext<T> |
SingleOperatorOnErrorResumeNext.withFunction(Single<? extends T> originalSingle,
Func1<Throwable,? extends Single<? extends T>> resumeFunctionInCaseOfError) |
Constructor and Description |
---|
CompletableFlatMapSingleToCompletable(Single<T> source,
Func1<? super T,? extends Completable> mapper) |
SingleDoAfterTerminate(Single<T> source,
Action0 action) |
SingleDoOnEvent(Single<T> source,
Action1<? super T> onSuccess,
Action1<Throwable> onError) |
SingleOnSubscribeDelaySubscriptionOther(Single<? extends T> main,
Observable<?> other) |
SingleOnSubscribeMap(Single<T> source,
Func1<? super T,? extends R> transformer) |
SingleTakeUntilSingle(Single.OnSubscribe<T> source,
Single<? extends U> other) |
Constructor and Description |
---|
OnSubscribeFlatMapSingle(Observable<T> source,
Func1<? super T,? extends Single<? extends R>> mapper,
boolean delayErrors,
int maxConcurrency) |
SingleOnSubscribeUsing(Func0<Resource> resourceFactory,
Func1<? super Resource,? extends Single<? extends T>> observableFactory,
Action1<? super Resource> disposeAction,
boolean disposeEagerly) |
Modifier and Type | Class and Description |
---|---|
class |
ScalarSynchronousSingle<T> |
Modifier and Type | Method and Description |
---|---|
<R> Single<R> |
ScalarSynchronousSingle.scalarFlatMap(Func1<? super T,? extends Single<? extends R>> func) |
Single<T> |
ScalarSynchronousSingle.scalarScheduleOn(Scheduler scheduler)
Customized observeOn/subscribeOn implementation which emits the scalar
value directly or with less overhead on the specified scheduler.
|
Modifier and Type | Method and Description |
---|---|
<R> Single<R> |
ScalarSynchronousSingle.scalarFlatMap(Func1<? super T,? extends Single<? extends R>> func) |
Modifier and Type | Method and Description |
---|---|
static Func2<Single,Single.OnSubscribe,Single.OnSubscribe> |
RxJavaHooks.getOnSingleStart()
Returns the current Single onStart hook function or null if it is
set to the default pass-through.
|
Modifier and Type | Method and Description |
---|---|
static <T> Single.OnSubscribe<T> |
RxJavaHooks.onSingleStart(Single<T> instance,
Single.OnSubscribe<T> onSubscribe)
Hook to call before the child subscriber is subscribed to the OnSubscribe action.
|
<T> Observable.OnSubscribe<T> |
RxJavaSingleExecutionHook.onSubscribeStart(Single<? extends T> singleInstance,
Observable.OnSubscribe<T> onSubscribe)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static void |
RxJavaHooks.setOnSingleStart(Func2<Single,Single.OnSubscribe,Single.OnSubscribe> onSingleStart)
Sets the hook function that is called when a subscriber subscribes to a Single
unless a lockdown is in effect.
|
Modifier and Type | Method and Description |
---|---|
static <T> BlockingSingle<T> |
BlockingSingle.from(Single<? extends T> single)
Converts a
Single into a BlockingSingle . |
Copyright © 2018. All rights reserved.