| Package | Description |
|---|---|
| rx |
Rx Observables
|
| rx.singles |
| Modifier and Type | Method and Description |
|---|---|
<R> Single |
Single.compose(Single
Transform a Single by applying a particular Transformer function to it.
|
static <T> Single |
Single.create(Single
Returns a Single that will execute the specified function when a
SingleSubscriber executes it or a
Subscriber subscribes to it.
|
static <T> Single |
Single.defer(Callable
|
Single |
Single.delay(long delay, TimeUnit
Returns an Single that emits the items emitted by the source Single shifted forward in time by a specified delay.
|
Single |
Single.delay(long delay, TimeUnit
Returns an Single that emits the items emitted by the source Single shifted forward in time by a specified delay.
|
Single |
Single.doOnError(Action1
Modifies the source
Single so that it invokes an action if it calls
onError.
|
Single |
Single.doOnSuccess(Action1
Modifies the source
Single so that it invokes an action when it calls
onSuccess.
|
static <T> Single |
Single.error(Throwable
Returns a Single that invokes a subscriber's
onError method when the subscriber subscribes to it.
|
<R> Single |
Single.flatMap(Func1
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 |
Single.from(Future
Converts a
Future into a
Single.
|
static <T> Single |
Single.from(Future
Converts a
Future into a
Single, with a timeout on the Future.
|
static <T> Single |
Single.from(Future
|
static <T> Single |
Single.fromCallable(Callable
Returns a
Single that invokes passed function and emits its result for each new Observer that subscribes.
|
static <T> Single |
Single.just(T value)
Returns a
Single that emits a specified item.
|
<R> Single |
Single.map(Func1
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 |
Single.merge(Single
Flattens a
Single that emits a
Single into a single
Single that emits the item emitted by the nested
Single, without any transformation.
|
Single |
Single.observeOn(Scheduler
Modifies a Single to emit its item (or notify of its error) on a specified
Scheduler, asynchronously.
|
Single |
Single.onErrorReturn(Func1
Instructs a Single to emit an item (returned by a specified function) rather than invoking
onError if it encounters an error.
|
Single |
Single.subscribeOn(Scheduler
Asynchronously subscribes subscribers to this Single on the specified
Scheduler.
|
Single |
Single.timeout(long timeout, TimeUnit
Returns a Single that mirrors the source Single but applies a timeout policy for its emitted item.
|
Single |
Single.timeout(long timeout, TimeUnit
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 |
Single.timeout(long timeout, TimeUnit
Returns a Single that mirrors the source Single but applies a timeout policy for its emitted item.
|
Single |
Single.timeout(long timeout, TimeUnit
Returns a Single that mirrors the source Single but applies a timeout policy for its emitted item, using a specified Scheduler.
|
Single |
Observable.toSingle()
Returns a Single that emits the single item emitted by the source Observable, if that Observable emits only a single item.
|
static <T1 |
Single.zip(Single
Returns a Single that emits the results of a specified combiner function applied to two items emitted by two other Singles.
|
static <T1 |
Single.zip(Single
Returns a Single that emits the results of a specified combiner function applied to three items emitted by three other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to four items emitted by four other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to five items emitted by five other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to six items emitted by six other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to seven items emitted by seven other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to eight items emitted by eight other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to nine items emitted by nine other Singles.
|
<T2 |
Single.zipWith(Single
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> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by two Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by two Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by three Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by three Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by three Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by four Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by four Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by four Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by four Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by five Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by five Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by five Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by five Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by five Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by six Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by six Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by six Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by six Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by six Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by six Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by seven Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by seven Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by seven Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by seven Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by seven Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by seven Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by seven Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by eight Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by eight Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by eight Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by eight Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by eight Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by eight Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by eight Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by eight Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by nine Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by nine Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by nine Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by nine Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by nine Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by nine Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by nine Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by nine Singles, one after the other.
|
static <T> Observable |
Single.concat(Single
Returns an Observable that emits the items emitted by nine Singles, one after the other.
|
Observable |
Single.concatWith(Single
Returns an Observable that emits the item emitted by the source Single, then the item emitted by the specified Single.
|
static <T> Single |
Single.merge(Single
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 |
Single.merge(Single
Flattens two Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens two Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens three Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens three Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens three Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens four Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens four Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens four Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens four Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens five Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens five Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens five Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens five Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens five Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens six Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens six Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens six Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens six Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens six Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens six Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens seven Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens seven Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens seven Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens seven Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens seven Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens seven Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens seven Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens eight Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens eight Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens eight Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens eight Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens eight Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens eight Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens eight Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens eight Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens nine Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens nine Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens nine Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens nine Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens nine Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens nine Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens nine Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens nine Singles into a single Observable, without any transformation.
|
static <T> Observable |
Single.merge(Single
Flattens nine Singles into a single Observable, without any transformation.
|
Observable |
Single.mergeWith(Single
Flattens this and another Single into a single Observable, without any transformation.
|
Single |
Single.timeout(long timeout, TimeUnit
Returns a Single that mirrors the source Single but applies a timeout policy for its emitted item.
|
Single |
Single.timeout(long timeout, TimeUnit
Returns a Single that mirrors the source Single but applies a timeout policy for its emitted item, using a specified Scheduler.
|
static <T1 |
Single.zip(Single
Returns a Single that emits the results of a specified combiner function applied to two items emitted by two other Singles.
|
static <T1 |
Single.zip(Single
Returns a Single that emits the results of a specified combiner function applied to two items emitted by two other Singles.
|
static <T1 |
Single.zip(Single
Returns a Single that emits the results of a specified combiner function applied to three items emitted by three other Singles.
|
static <T1 |
Single.zip(Single
Returns a Single that emits the results of a specified combiner function applied to three items emitted by three other Singles.
|
static <T1 |
Single.zip(Single
Returns a Single that emits the results of a specified combiner function applied to three items emitted by three other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to four items emitted by four other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to four items emitted by four other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to four items emitted by four other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to four items emitted by four other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to five items emitted by five other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to five items emitted by five other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to five items emitted by five other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to five items emitted by five other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to five items emitted by five other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to six items emitted by six other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to six items emitted by six other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to six items emitted by six other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to six items emitted by six other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to six items emitted by six other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to six items emitted by six other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to seven items emitted by seven other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to seven items emitted by seven other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to seven items emitted by seven other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to seven items emitted by seven other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to seven items emitted by seven other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to seven items emitted by seven other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to seven items emitted by seven other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to eight items emitted by eight other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to eight items emitted by eight other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to eight items emitted by eight other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to eight items emitted by eight other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to eight items emitted by eight other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to eight items emitted by eight other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to eight items emitted by eight other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to eight items emitted by eight other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to nine items emitted by nine other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to nine items emitted by nine other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to nine items emitted by nine other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to nine items emitted by nine other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to nine items emitted by nine other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to nine items emitted by nine other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to nine items emitted by nine other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to nine items emitted by nine other Singles.
|
static <T1 |
Single.zip(Single
Returns an Observable that emits the results of a specified combiner function applied to nine items emitted by nine other Singles.
|
<T2 |
Single.zipWith(Single
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 |
Single.defer(Callable
|
<R> Single |
Single.flatMap(Func1
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 |
Single.merge(Single
Flattens a
Single that emits a
Single into a single
Single that emits the item emitted by the nested
Single, without any transformation.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> BlockingSingle |
BlockingSingle.from(Single
Converts a
Single into a
BlockingSingle.
|