Package | Description |
---|---|
io.reactivex |
Base reactive classes:
Flowable , Observable ,
Single , Maybe and
Completable ; base reactive consumers;
other common base interfaces. |
io.reactivex.internal.functions | |
io.reactivex.internal.operators.completable | |
io.reactivex.internal.operators.flowable | |
io.reactivex.internal.operators.maybe | |
io.reactivex.internal.operators.mixed | |
io.reactivex.internal.operators.observable | |
io.reactivex.internal.operators.parallel | |
io.reactivex.internal.operators.single | |
io.reactivex.internal.schedulers | |
io.reactivex.internal.util | |
io.reactivex.parallel |
Contains the base type
ParallelFlowable ,
a sub-DSL for working with Flowable sequences in parallel. |
io.reactivex.plugins |
Contains the central plugin handler
RxJavaPlugins
class to hook into the lifecycle of the base reactive types and schedulers. |
Modifier and Type | Method and Description |
---|---|
<TOpening,TClosing> |
Flowable.buffer(Flowable<? extends TOpening> openingIndicator,
Function<? super TOpening,? extends org.reactivestreams.Publisher<? extends TClosing>> closingIndicator)
Returns a Flowable that emits buffers of items it collects from the source Publisher.
|
<TOpening,TClosing,U extends Collection<? super T>> |
Flowable.buffer(Flowable<? extends TOpening> openingIndicator,
Function<? super TOpening,? extends org.reactivestreams.Publisher<? extends TClosing>> closingIndicator,
Callable<U> bufferSupplier)
Returns a Flowable that emits buffers of items it collects from the source Publisher.
|
<TOpening,TClosing> |
Observable.buffer(ObservableSource<? extends TOpening> openingIndicator,
Function<? super TOpening,? extends ObservableSource<? extends TClosing>> closingIndicator)
Returns an Observable that emits buffers of items it collects from the source ObservableSource.
|
<TOpening,TClosing,U extends Collection<? super T>> |
Observable.buffer(ObservableSource<? extends TOpening> openingIndicator,
Function<? super TOpening,? extends ObservableSource<? extends TClosing>> closingIndicator,
Callable<U> bufferSupplier)
Returns an Observable that emits buffers of items it collects from the source ObservableSource.
|
static <T,R> Observable<R> |
Observable.combineLatest(Function<? super Object[],? extends R> combiner,
int bufferSize,
ObservableSource<? extends T>... sources)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T,R> Flowable<R> |
Flowable.combineLatest(Function<? super Object[],? extends R> combiner,
org.reactivestreams.Publisher<? extends T>... sources)
Combines a collection of source Publishers by emitting an item that aggregates the latest values of each of
the source Publishers each time an item is received from any of the source Publishers, where this
aggregation is defined by a specified function.
|
static <T,R> Observable<R> |
Observable.combineLatest(Iterable<? extends ObservableSource<? extends T>> sources,
Function<? super Object[],? extends R> combiner)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T,R> Observable<R> |
Observable.combineLatest(Iterable<? extends ObservableSource<? extends T>> sources,
Function<? super Object[],? extends R> combiner,
int bufferSize)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T,R> Flowable<R> |
Flowable.combineLatest(Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources,
Function<? super Object[],? extends R> combiner)
Combines a collection of source Publishers by emitting an item that aggregates the latest values of each of
the source Publishers each time an item is received from any of the source Publishers, where this
aggregation is defined by a specified function.
|
static <T,R> Flowable<R> |
Flowable.combineLatest(Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources,
Function<? super Object[],? extends R> combiner,
int bufferSize)
Combines a collection of source Publishers by emitting an item that aggregates the latest values of each of
the source Publishers each time an item is received from any of the source Publishers, where this
aggregation is defined by a specified function.
|
static <T,R> Observable<R> |
Observable.combineLatest(ObservableSource<? extends T>[] sources,
Function<? super Object[],? extends R> combiner)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T,R> Observable<R> |
Observable.combineLatest(ObservableSource<? extends T>[] sources,
Function<? super Object[],? extends R> combiner,
int bufferSize)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T,R> Flowable<R> |
Flowable.combineLatest(org.reactivestreams.Publisher<? extends T>[] sources,
Function<? super Object[],? extends R> combiner)
Combines a collection of source Publishers by emitting an item that aggregates the latest values of each of
the source Publishers each time an item is received from any of the source Publishers, where this
aggregation is defined by a specified function.
|
static <T,R> Flowable<R> |
Flowable.combineLatest(org.reactivestreams.Publisher<? extends T>[] sources,
Function<? super Object[],? extends R> combiner,
int bufferSize)
Combines a collection of source Publishers by emitting an item that aggregates the latest values of each of
the source Publishers each time an item is received from any of the source Publishers, where this
aggregation is defined by a specified function.
|
static <T,R> Observable<R> |
Observable.combineLatestDelayError(Function<? super Object[],? extends R> combiner,
int bufferSize,
ObservableSource<? extends T>... sources)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function and delays any error from the sources until
all source ObservableSources terminate.
|
static <T,R> Flowable<R> |
Flowable.combineLatestDelayError(Function<? super Object[],? extends R> combiner,
int bufferSize,
org.reactivestreams.Publisher<? extends T>... sources)
Combines a collection of source Publishers by emitting an item that aggregates the latest values of each of
the source Publishers each time an item is received from any of the source Publisher, where this
aggregation is defined by a specified function and delays any error from the sources until
all source Publishers terminate.
|
static <T,R> Flowable<R> |
Flowable.combineLatestDelayError(Function<? super Object[],? extends R> combiner,
org.reactivestreams.Publisher<? extends T>... sources)
Combines a collection of source Publishers by emitting an item that aggregates the latest values of each of
the source Publishers each time an item is received from any of the source Publishers, where this
aggregation is defined by a specified function and delays any error from the sources until
all source Publishers terminate.
|
static <T,R> Observable<R> |
Observable.combineLatestDelayError(Iterable<? extends ObservableSource<? extends T>> sources,
Function<? super Object[],? extends R> combiner)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function and delays any error from the sources until
all source ObservableSources terminate.
|
static <T,R> Observable<R> |
Observable.combineLatestDelayError(Iterable<? extends ObservableSource<? extends T>> sources,
Function<? super Object[],? extends R> combiner,
int bufferSize)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function and delays any error from the sources until
all source ObservableSources terminate.
|
static <T,R> Flowable<R> |
Flowable.combineLatestDelayError(Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources,
Function<? super Object[],? extends R> combiner)
Combines a collection of source Publishers by emitting an item that aggregates the latest values of each of
the source Publishers each time an item is received from any of the source Publishers, where this
aggregation is defined by a specified function and delays any error from the sources until
all source Publishers terminate.
|
static <T,R> Flowable<R> |
Flowable.combineLatestDelayError(Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources,
Function<? super Object[],? extends R> combiner,
int bufferSize)
Combines a collection of source Publishers by emitting an item that aggregates the latest values of each of
the source Publishers each time an item is received from any of the source Publishers, where this
aggregation is defined by a specified function and delays any error from the sources until
all source Publishers terminate.
|
static <T,R> Observable<R> |
Observable.combineLatestDelayError(ObservableSource<? extends T>[] sources,
Function<? super Object[],? extends R> combiner)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function.
|
static <T,R> Observable<R> |
Observable.combineLatestDelayError(ObservableSource<? extends T>[] sources,
Function<? super Object[],? extends R> combiner,
int bufferSize)
Combines a collection of source ObservableSources by emitting an item that aggregates the latest values of each of
the source ObservableSources each time an item is received from any of the source ObservableSources, where this
aggregation is defined by a specified function and delays any error from the sources until
all source ObservableSources terminate.
|
static <T,R> Flowable<R> |
Flowable.combineLatestDelayError(org.reactivestreams.Publisher<? extends T>[] sources,
Function<? super Object[],? extends R> combiner)
Combines a collection of source Publishers by emitting an item that aggregates the latest values of each of
the source Publishers each time an item is received from any of the source Publishers, where this
aggregation is defined by a specified function.
|
static <T,R> Flowable<R> |
Flowable.combineLatestDelayError(org.reactivestreams.Publisher<? extends T>[] sources,
Function<? super Object[],? extends R> combiner,
int bufferSize)
Combines a collection of source Publishers by emitting an item that aggregates the latest values of each of
the source Publishers each time an item is received from any of the source Publishers, where this
aggregation is defined by a specified function and delays any error from the sources until
all source Publishers terminate.
|
<R> Maybe<R> |
Maybe.concatMap(Function<? super T,? extends MaybeSource<? extends R>> mapper)
Returns a Maybe that is based on applying a specified function to the item emitted by the source Maybe,
where that function returns a MaybeSource.
|
<R> Observable<R> |
Observable.concatMap(Function<? super T,? extends ObservableSource<? extends R>> mapper)
Returns a new Observable that emits items resulting from applying a function that you supply to each item
emitted by the source ObservableSource, where that function returns an ObservableSource, and then emitting the items
that result from concatenating those resulting ObservableSources.
|
<R> Observable<R> |
Observable.concatMap(Function<? super T,? extends ObservableSource<? extends R>> mapper,
int prefetch)
Returns a new Observable that emits items resulting from applying a function that you supply to each item
emitted by the source ObservableSource, where that function returns an ObservableSource, and then emitting the items
that result from concatenating those resulting ObservableSources.
|
<R> Flowable<R> |
Flowable.concatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper)
Returns a new Flowable that emits items resulting from applying a function that you supply to each item
emitted by the source Publisher, where that function returns a Publisher, and then emitting the items
that result from concatenating those resulting Publishers.
|
<R> Flowable<R> |
Flowable.concatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
int prefetch)
Returns a new Flowable that emits items resulting from applying a function that you supply to each item
emitted by the source Publisher, where that function returns a Publisher, and then emitting the items
that result from concatenating those resulting Publishers.
|
Completable |
Observable.concatMapCompletable(Function<? super T,? extends CompletableSource> mapper)
Maps each element of the upstream Observable into CompletableSources, subscribes to them one at a time in
order and waits until the upstream and all CompletableSources complete.
|
Completable |
Flowable.concatMapCompletable(Function<? super T,? extends CompletableSource> mapper)
Maps the upstream items into
CompletableSource s and subscribes to them one after the
other completes. |
Completable |
Observable.concatMapCompletable(Function<? super T,? extends CompletableSource> mapper,
int capacityHint)
Maps each element of the upstream Observable into CompletableSources, subscribes to them one at a time in
order and waits until the upstream and all CompletableSources complete.
|
Completable |
Flowable.concatMapCompletable(Function<? super T,? extends CompletableSource> mapper,
int prefetch)
Maps the upstream items into
CompletableSource s and subscribes to them one after the
other completes. |
Completable |
Observable.concatMapCompletableDelayError(Function<? super T,? extends CompletableSource> mapper)
Maps the upstream items into
CompletableSource s and subscribes to them one after the
other terminates, delaying all errors till both this Observable and all
inner CompletableSource s terminate. |
Completable |
Flowable.concatMapCompletableDelayError(Function<? super T,? extends CompletableSource> mapper)
Maps the upstream items into
CompletableSource s and subscribes to them one after the
other terminates, delaying all errors till both this Flowable and all
inner CompletableSource s terminate. |
Completable |
Observable.concatMapCompletableDelayError(Function<? super T,? extends CompletableSource> mapper,
boolean tillTheEnd)
Maps the upstream items into
CompletableSource s and subscribes to them one after the
other terminates, optionally delaying all errors till both this Observable and all
inner CompletableSource s terminate. |
Completable |
Flowable.concatMapCompletableDelayError(Function<? super T,? extends CompletableSource> mapper,
boolean tillTheEnd)
Maps the upstream items into
CompletableSource s and subscribes to them one after the
other terminates, optionally delaying all errors till both this Flowable and all
inner CompletableSource s terminate. |
Completable |
Observable.concatMapCompletableDelayError(Function<? super T,? extends CompletableSource> mapper,
boolean tillTheEnd,
int prefetch)
Maps the upstream items into
CompletableSource s and subscribes to them one after the
other terminates, optionally delaying all errors till both this Observable and all
inner CompletableSource s terminate. |
Completable |
Flowable.concatMapCompletableDelayError(Function<? super T,? extends CompletableSource> mapper,
boolean tillTheEnd,
int prefetch)
Maps the upstream items into
CompletableSource s and subscribes to them one after the
other terminates, optionally delaying all errors till both this Flowable and all
inner CompletableSource s terminate. |
<R> Observable<R> |
Observable.concatMapDelayError(Function<? super T,? extends ObservableSource<? extends R>> mapper)
Maps each of the items into an ObservableSource, 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 ObservableSources
till all of them terminate.
|
<R> Observable<R> |
Observable.concatMapDelayError(Function<? super T,? extends ObservableSource<? extends R>> mapper,
int prefetch,
boolean tillTheEnd)
Maps each of the items into an ObservableSource, 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 ObservableSources
till all of them terminate.
|
<R> Flowable<R> |
Flowable.concatMapDelayError(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper)
Maps each of the items into a Publisher, 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 Publishers
till all of them terminate.
|
<R> Flowable<R> |
Flowable.concatMapDelayError(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
int prefetch,
boolean tillTheEnd)
Maps each of the items into a Publisher, 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 Publishers
till all of them terminate.
|
<R> Observable<R> |
Observable.concatMapEager(Function<? super T,? extends ObservableSource<? extends R>> mapper)
Maps a sequence of values into ObservableSources and concatenates these ObservableSources eagerly into a single
ObservableSource.
|
<R> Observable<R> |
Observable.concatMapEager(Function<? super T,? extends ObservableSource<? extends R>> mapper,
int maxConcurrency,
int prefetch)
Maps a sequence of values into ObservableSources and concatenates these ObservableSources eagerly into a single
ObservableSource.
|
<R> Flowable<R> |
Flowable.concatMapEager(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper)
Maps a sequence of values into Publishers and concatenates these Publishers eagerly into a single
Publisher.
|
<R> Flowable<R> |
Flowable.concatMapEager(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
int maxConcurrency,
int prefetch)
Maps a sequence of values into Publishers and concatenates these Publishers eagerly into a single
Publisher.
|
<R> Observable<R> |
Observable.concatMapEagerDelayError(Function<? super T,? extends ObservableSource<? extends R>> mapper,
boolean tillTheEnd)
Maps a sequence of values into ObservableSources and concatenates these ObservableSources eagerly into a single
ObservableSource.
|
<R> Observable<R> |
Observable.concatMapEagerDelayError(Function<? super T,? extends ObservableSource<? extends R>> mapper,
int maxConcurrency,
int prefetch,
boolean tillTheEnd)
Maps a sequence of values into ObservableSources and concatenates these ObservableSources eagerly into a single
ObservableSource.
|
<R> Flowable<R> |
Flowable.concatMapEagerDelayError(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
boolean tillTheEnd)
Maps a sequence of values into Publishers and concatenates these Publishers eagerly into a single
Publisher.
|
<R> Flowable<R> |
Flowable.concatMapEagerDelayError(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
int maxConcurrency,
int prefetch,
boolean tillTheEnd)
Maps a sequence of values into Publishers and concatenates these Publishers eagerly into a single
Publisher.
|
<U> Observable<U> |
Observable.concatMapIterable(Function<? super T,? extends Iterable<? extends U>> mapper)
Returns an Observable that concatenate each item emitted by the source ObservableSource with the values in an
Iterable corresponding to that item that is generated by a selector.
|
<U> Flowable<U> |
Flowable.concatMapIterable(Function<? super T,? extends Iterable<? extends U>> mapper)
Returns a Flowable that concatenate each item emitted by the source Publisher with the values in an
Iterable corresponding to that item that is generated by a selector.
|
<U> Observable<U> |
Observable.concatMapIterable(Function<? super T,? extends Iterable<? extends U>> mapper,
int prefetch)
Returns an Observable that concatenate each item emitted by the source ObservableSource with the values in an
Iterable corresponding to that item that is generated by a selector.
|
<U> Flowable<U> |
Flowable.concatMapIterable(Function<? super T,? extends Iterable<? extends U>> mapper,
int prefetch)
Returns a Flowable that concatenate each item emitted by the source Publisher with the values in an
Iterable corresponding to that item that is generated by a selector.
|
<R> Observable<R> |
Observable.concatMapMaybe(Function<? super T,? extends MaybeSource<? extends R>> mapper)
Maps the upstream items into
MaybeSource s and subscribes to them one after the
other succeeds or completes, emits their success value if available or terminates immediately if
either this Observable or the current inner MaybeSource fail. |
<R> Flowable<R> |
Flowable.concatMapMaybe(Function<? super T,? extends MaybeSource<? extends R>> mapper)
Maps the upstream items into
MaybeSource s and subscribes to them one after the
other succeeds or completes, emits their success value if available or terminates immediately if
either this Flowable or the current inner MaybeSource fail. |
<R> Observable<R> |
Observable.concatMapMaybe(Function<? super T,? extends MaybeSource<? extends R>> mapper,
int prefetch)
Maps the upstream items into
MaybeSource s and subscribes to them one after the
other succeeds or completes, emits their success value if available or terminates immediately if
either this Observable or the current inner MaybeSource fail. |
<R> Flowable<R> |
Flowable.concatMapMaybe(Function<? super T,? extends MaybeSource<? extends R>> mapper,
int prefetch)
Maps the upstream items into
MaybeSource s and subscribes to them one after the
other succeeds or completes, emits their success value if available or terminates immediately if
either this Flowable or the current inner MaybeSource fail. |
<R> Observable<R> |
Observable.concatMapMaybeDelayError(Function<? super T,? extends MaybeSource<? extends R>> mapper)
Maps the upstream items into
MaybeSource s and subscribes to them one after the
other terminates, emits their success value if available and delaying all errors
till both this Observable and all inner MaybeSource s terminate. |
<R> Flowable<R> |
Flowable.concatMapMaybeDelayError(Function<? super T,? extends MaybeSource<? extends R>> mapper)
Maps the upstream items into
MaybeSource s and subscribes to them one after the
other terminates, emits their success value if available and delaying all errors
till both this Flowable and all inner MaybeSource s terminate. |
<R> Observable<R> |
Observable.concatMapMaybeDelayError(Function<? super T,? extends MaybeSource<? extends R>> mapper,
boolean tillTheEnd)
Maps the upstream items into
MaybeSource s and subscribes to them one after the
other terminates, emits their success value if available and optionally delaying all errors
till both this Observable and all inner MaybeSource s terminate. |
<R> Flowable<R> |
Flowable.concatMapMaybeDelayError(Function<? super T,? extends MaybeSource<? extends R>> mapper,
boolean tillTheEnd)
Maps the upstream items into
MaybeSource s and subscribes to them one after the
other terminates, emits their success value if available and optionally delaying all errors
till both this Flowable and all inner MaybeSource s terminate. |
<R> Observable<R> |
Observable.concatMapMaybeDelayError(Function<? super T,? extends MaybeSource<? extends R>> mapper,
boolean tillTheEnd,
int prefetch)
Maps the upstream items into
MaybeSource s and subscribes to them one after the
other terminates, emits their success value if available and optionally delaying all errors
till both this Observable and all inner MaybeSource s terminate. |
<R> Flowable<R> |
Flowable.concatMapMaybeDelayError(Function<? super T,? extends MaybeSource<? extends R>> mapper,
boolean tillTheEnd,
int prefetch)
Maps the upstream items into
MaybeSource s and subscribes to them one after the
other terminates, emits their success value if available and optionally delaying all errors
till both this Flowable and all inner MaybeSource s terminate. |
<R> Observable<R> |
Observable.concatMapSingle(Function<? super T,? extends SingleSource<? extends R>> mapper)
Maps the upstream items into
SingleSource s and subscribes to them one after the
other succeeds, emits their success values or terminates immediately if
either this Observable or the current inner SingleSource fail. |
<R> Flowable<R> |
Flowable.concatMapSingle(Function<? super T,? extends SingleSource<? extends R>> mapper)
Maps the upstream items into
SingleSource s and subscribes to them one after the
other succeeds, emits their success values or terminates immediately if
either this Flowable or the current inner SingleSource fail. |
<R> Observable<R> |
Observable.concatMapSingle(Function<? super T,? extends SingleSource<? extends R>> mapper,
int prefetch)
Maps the upstream items into
SingleSource s and subscribes to them one after the
other succeeds, emits their success values or terminates immediately if
either this Observable or the current inner SingleSource fail. |
<R> Flowable<R> |
Flowable.concatMapSingle(Function<? super T,? extends SingleSource<? extends R>> mapper,
int prefetch)
Maps the upstream items into
SingleSource s and subscribes to them one after the
other succeeds, emits their success values or terminates immediately if
either this Flowable or the current inner SingleSource fail. |
<R> Observable<R> |
Observable.concatMapSingleDelayError(Function<? super T,? extends SingleSource<? extends R>> mapper)
Maps the upstream items into
SingleSource s and subscribes to them one after the
other succeeds or fails, emits their success values and delays all errors
till both this Observable and all inner SingleSource s terminate. |
<R> Flowable<R> |
Flowable.concatMapSingleDelayError(Function<? super T,? extends SingleSource<? extends R>> mapper)
Maps the upstream items into
SingleSource s and subscribes to them one after the
other succeeds or fails, emits their success values and delays all errors
till both this Flowable and all inner SingleSource s terminate. |
<R> Observable<R> |
Observable.concatMapSingleDelayError(Function<? super T,? extends SingleSource<? extends R>> mapper,
boolean tillTheEnd)
Maps the upstream items into
SingleSource s and subscribes to them one after the
other succeeds or fails, emits their success values and optionally delays all errors
till both this Observable and all inner SingleSource s terminate. |
<R> Flowable<R> |
Flowable.concatMapSingleDelayError(Function<? super T,? extends SingleSource<? extends R>> mapper,
boolean tillTheEnd)
Maps the upstream items into
SingleSource s and subscribes to them one after the
other succeeds or fails, emits their success values and optionally delays all errors
till both this Flowable and all inner SingleSource s terminate. |
<R> Observable<R> |
Observable.concatMapSingleDelayError(Function<? super T,? extends SingleSource<? extends R>> mapper,
boolean tillTheEnd,
int prefetch)
Maps the upstream items into
SingleSource s and subscribes to them one after the
other succeeds or fails, emits their success values and optionally delays errors
till both this Observable and all inner SingleSource s terminate. |
<R> Flowable<R> |
Flowable.concatMapSingleDelayError(Function<? super T,? extends SingleSource<? extends R>> mapper,
boolean tillTheEnd,
int prefetch)
Maps the upstream items into
SingleSource s and subscribes to them one after the
other succeeds or fails, emits their success values and optionally delays errors
till both this Flowable and all inner SingleSource s terminate. |
<U> Observable<T> |
Observable.debounce(Function<? super T,? extends ObservableSource<U>> debounceSelector)
Returns an Observable that mirrors the source ObservableSource, except that it drops items emitted by the
source ObservableSource that are followed by another item within a computed debounce duration.
|
<U> Flowable<T> |
Flowable.debounce(Function<? super T,? extends org.reactivestreams.Publisher<U>> debounceIndicator)
Returns a Flowable that mirrors the source Publisher, except that it drops items emitted by the
source Publisher that are followed by another item within a computed debounce duration.
|
<U> Observable<T> |
Observable.delay(Function<? super T,? extends ObservableSource<U>> itemDelay)
Returns an Observable that delays the emissions of the source ObservableSource via another ObservableSource on a
per-item basis.
|
<U> Flowable<T> |
Flowable.delay(Function<? super T,? extends org.reactivestreams.Publisher<U>> itemDelayIndicator)
Returns a Flowable that delays the emissions of the source Publisher via another Publisher on a
per-item basis.
|
<U,V> Observable<T> |
Observable.delay(ObservableSource<U> subscriptionDelay,
Function<? super T,? extends ObservableSource<V>> itemDelay)
Returns an Observable that delays the subscription to and emissions from the source ObservableSource via another
ObservableSource on a per-item basis.
|
<U,V> Flowable<T> |
Flowable.delay(org.reactivestreams.Publisher<U> subscriptionIndicator,
Function<? super T,? extends org.reactivestreams.Publisher<V>> itemDelayIndicator)
Returns a Flowable that delays the subscription to and emissions from the source Publisher via another
Publisher on a per-item basis.
|
<R> Maybe<R> |
Single.dematerialize(Function<? super T,Notification<R>> selector)
Maps the
Notification success value of this Single back into normal
onSuccess , onError or onComplete signals as a
Maybe source. |
<R> Observable<R> |
Observable.dematerialize(Function<? super T,Notification<R>> selector)
Returns an Observable that reverses the effect of
materialize by transforming the
Notification objects extracted from the source items via a selector function
into their respective Observer signal types. |
<R> Flowable<R> |
Flowable.dematerialize(Function<? super T,Notification<R>> selector)
Returns a Flowable that reverses the effect of
materialize by transforming the
Notification objects extracted from the source items via a selector function
into their respective Subscriber signal types. |
<K> Observable<T> |
Observable.distinct(Function<? super T,K> keySelector)
Returns an Observable that emits all items emitted by the source ObservableSource that are distinct according
to a key selector function and based on
Object.equals(Object) comparison of the objects
returned by the key selector function. |
<K> Flowable<T> |
Flowable.distinct(Function<? super T,K> keySelector)
Returns a Flowable that emits all items emitted by the source Publisher that are distinct according
to a key selector function and based on
Object.equals(Object) comparison of the objects
returned by the key selector function. |
<K> Observable<T> |
Observable.distinct(Function<? super T,K> keySelector,
Callable<? extends Collection<? super K>> collectionSupplier)
Returns an Observable that emits all items emitted by the source ObservableSource that are distinct according
to a key selector function and based on
Object.equals(Object) comparison of the objects
returned by the key selector function. |
<K> Flowable<T> |
Flowable.distinct(Function<? super T,K> keySelector,
Callable<? extends Collection<? super K>> collectionSupplier)
Returns a Flowable that emits all items emitted by the source Publisher that are distinct according
to a key selector function and based on
Object.equals(Object) comparison of the objects
returned by the key selector function. |
<K> Observable<T> |
Observable.distinctUntilChanged(Function<? super T,K> keySelector)
Returns an Observable that emits all items emitted by the source ObservableSource that are distinct from their
immediate predecessors, according to a key selector function and based on
Object.equals(Object) comparison
of those objects returned by the key selector function. |
<K> Flowable<T> |
Flowable.distinctUntilChanged(Function<? super T,K> keySelector)
Returns a Flowable that emits all items emitted by the source Publisher that are distinct from their
immediate predecessors, according to a key selector function and based on
Object.equals(Object) comparison
of those objects returned by the key selector function. |
<R> Maybe<R> |
Maybe.flatMap(Function<? super T,? extends MaybeSource<? extends R>> mapper)
Returns a Maybe that is based on applying a specified function to the item emitted by the source Maybe,
where that function returns a MaybeSource.
|
<R> Maybe<R> |
Maybe.flatMap(Function<? super T,? extends MaybeSource<? extends R>> onSuccessMapper,
Function<? super Throwable,? extends MaybeSource<? extends R>> onErrorMapper,
Callable<? extends MaybeSource<? extends R>> onCompleteSupplier)
Maps the onSuccess, onError or onComplete signals of this Maybe into MaybeSource and emits that
MaybeSource's signals.
|
<R> Maybe<R> |
Maybe.flatMap(Function<? super T,? extends MaybeSource<? extends R>> onSuccessMapper,
Function<? super Throwable,? extends MaybeSource<? extends R>> onErrorMapper,
Callable<? extends MaybeSource<? extends R>> onCompleteSupplier)
Maps the onSuccess, onError or onComplete signals of this Maybe into MaybeSource and emits that
MaybeSource's signals.
|
<U,R> Maybe<R> |
Maybe.flatMap(Function<? super T,? extends MaybeSource<? extends U>> mapper,
BiFunction<? super T,? super U,? extends R> resultSelector)
Returns a Maybe that emits the results of a specified function to the pair of values emitted by the
source Maybe and a specified mapped MaybeSource.
|
<R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends R>> mapper)
Returns an Observable that emits items based on applying a function that you supply to each item emitted
by the source ObservableSource, where that function returns an ObservableSource, and then merging those resulting
ObservableSources and emitting the results of this merger.
|
<R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends R>> mapper,
boolean delayErrors)
Returns an Observable that emits items based on applying a function that you supply to each item emitted
by the source ObservableSource, where that function returns an ObservableSource, and then merging those resulting
ObservableSources and emitting the results of this merger.
|
<R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends R>> mapper,
boolean delayErrors,
int maxConcurrency)
Returns an Observable that emits items based on applying a function that you supply to each item emitted
by the source ObservableSource, where that function returns an ObservableSource, and then merging those resulting
ObservableSources and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these ObservableSources.
|
<R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends R>> mapper,
boolean delayErrors,
int maxConcurrency,
int bufferSize)
Returns an Observable that emits items based on applying a function that you supply to each item emitted
by the source ObservableSource, where that function returns an ObservableSource, and then merging those resulting
ObservableSources and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these ObservableSources.
|
<R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends R>> onNextMapper,
Function<? super Throwable,? extends ObservableSource<? extends R>> onErrorMapper,
Callable<? extends ObservableSource<? extends R>> onCompleteSupplier)
Returns an Observable that applies a function to each item emitted or notification raised by the source
ObservableSource and then flattens the ObservableSources returned from these functions and emits the resulting items.
|
<R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends R>> onNextMapper,
Function<? super Throwable,? extends ObservableSource<? extends R>> onErrorMapper,
Callable<? extends ObservableSource<? extends R>> onCompleteSupplier)
Returns an Observable that applies a function to each item emitted or notification raised by the source
ObservableSource and then flattens the ObservableSources returned from these functions and emits the resulting items.
|
<R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends R>> onNextMapper,
Function<Throwable,? extends ObservableSource<? extends R>> onErrorMapper,
Callable<? extends ObservableSource<? extends R>> onCompleteSupplier,
int maxConcurrency)
Returns an Observable that applies a function to each item emitted or notification raised by the source
ObservableSource and then flattens the ObservableSources returned from these functions and emits the resulting items,
while limiting the maximum number of concurrent subscriptions to these ObservableSources.
|
<R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends R>> onNextMapper,
Function<Throwable,? extends ObservableSource<? extends R>> onErrorMapper,
Callable<? extends ObservableSource<? extends R>> onCompleteSupplier,
int maxConcurrency)
Returns an Observable that applies a function to each item emitted or notification raised by the source
ObservableSource and then flattens the ObservableSources returned from these functions and emits the resulting items,
while limiting the maximum number of concurrent subscriptions to these ObservableSources.
|
<R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends R>> mapper,
int maxConcurrency)
Returns an Observable that emits items based on applying a function that you supply to each item emitted
by the source ObservableSource, where that function returns an ObservableSource, and then merging those resulting
ObservableSources and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these ObservableSources.
|
<U,R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends U>> mapper,
BiFunction<? super T,? super U,? extends R> resultSelector)
Returns an Observable that emits the results of a specified function to the pair of values emitted by the
source ObservableSource and a specified collection ObservableSource.
|
<U,R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends U>> mapper,
BiFunction<? super T,? super U,? extends R> combiner,
boolean delayErrors)
Returns an Observable that emits the results of a specified function to the pair of values emitted by the
source ObservableSource and a specified collection ObservableSource.
|
<U,R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends U>> mapper,
BiFunction<? super T,? super U,? extends R> combiner,
boolean delayErrors,
int maxConcurrency)
Returns an Observable that emits the results of a specified function to the pair of values emitted by the
source ObservableSource and a specified collection ObservableSource, while limiting the maximum number of concurrent
subscriptions to these ObservableSources.
|
<U,R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends U>> mapper,
BiFunction<? super T,? super U,? extends R> combiner,
boolean delayErrors,
int maxConcurrency,
int bufferSize)
Returns an Observable that emits the results of a specified function to the pair of values emitted by the
source ObservableSource and a specified collection ObservableSource, while limiting the maximum number of concurrent
subscriptions to these ObservableSources.
|
<U,R> Observable<R> |
Observable.flatMap(Function<? super T,? extends ObservableSource<? extends U>> mapper,
BiFunction<? super T,? super U,? extends R> combiner,
int maxConcurrency)
Returns an Observable that emits the results of a specified function to the pair of values emitted by the
source ObservableSource and a specified collection ObservableSource, while limiting the maximum number of concurrent
subscriptions to these ObservableSources.
|
<R> Flowable<R> |
Flowable.flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper)
Returns a Flowable that emits items based on applying a function that you supply to each item emitted
by the source Publisher, where that function returns a Publisher, and then merging those resulting
Publishers and emitting the results of this merger.
|
<R> Flowable<R> |
Flowable.flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
boolean delayErrors)
Returns a Flowable that emits items based on applying a function that you supply to each item emitted
by the source Publisher, where that function returns a Publisher, and then merging those resulting
Publishers and emitting the results of this merger.
|
<R> Flowable<R> |
Flowable.flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
boolean delayErrors,
int maxConcurrency)
Returns a Flowable that emits items based on applying a function that you supply to each item emitted
by the source Publisher, where that function returns a Publisher, and then merging those resulting
Publishers and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these Publishers.
|
<R> Flowable<R> |
Flowable.flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
boolean delayErrors,
int maxConcurrency,
int bufferSize)
Returns a Flowable that emits items based on applying a function that you supply to each item emitted
by the source Publisher, where that function returns a Publisher, and then merging those resulting
Publishers and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these Publishers.
|
<R> Flowable<R> |
Flowable.flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> onNextMapper,
Function<? super Throwable,? extends org.reactivestreams.Publisher<? extends R>> onErrorMapper,
Callable<? extends org.reactivestreams.Publisher<? extends R>> onCompleteSupplier)
Returns a Flowable that applies a function to each item emitted or notification raised by the source
Publisher and then flattens the Publishers returned from these functions and emits the resulting items.
|
<R> Flowable<R> |
Flowable.flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> onNextMapper,
Function<? super Throwable,? extends org.reactivestreams.Publisher<? extends R>> onErrorMapper,
Callable<? extends org.reactivestreams.Publisher<? extends R>> onCompleteSupplier)
Returns a Flowable that applies a function to each item emitted or notification raised by the source
Publisher and then flattens the Publishers returned from these functions and emits the resulting items.
|
<R> Flowable<R> |
Flowable.flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> onNextMapper,
Function<Throwable,? extends org.reactivestreams.Publisher<? extends R>> onErrorMapper,
Callable<? extends org.reactivestreams.Publisher<? extends R>> onCompleteSupplier,
int maxConcurrency)
Returns a Flowable that applies a function to each item emitted or notification raised by the source
Publisher and then flattens the Publishers returned from these functions and emits the resulting items,
while limiting the maximum number of concurrent subscriptions to these Publishers.
|
<R> Flowable<R> |
Flowable.flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> onNextMapper,
Function<Throwable,? extends org.reactivestreams.Publisher<? extends R>> onErrorMapper,
Callable<? extends org.reactivestreams.Publisher<? extends R>> onCompleteSupplier,
int maxConcurrency)
Returns a Flowable that applies a function to each item emitted or notification raised by the source
Publisher and then flattens the Publishers returned from these functions and emits the resulting items,
while limiting the maximum number of concurrent subscriptions to these Publishers.
|
<R> Flowable<R> |
Flowable.flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
int maxConcurrency)
Returns a Flowable that emits items based on applying a function that you supply to each item emitted
by the source Publisher, where that function returns a Publisher, and then merging those resulting
Publishers and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these Publishers.
|
<U,R> Flowable<R> |
Flowable.flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends U>> mapper,
BiFunction<? super T,? super U,? extends R> combiner)
Returns a Flowable that emits the results of a specified function to the pair of values emitted by the
source Publisher and a specified collection Publisher.
|
<U,R> Flowable<R> |
Flowable.flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends U>> mapper,
BiFunction<? super T,? super U,? extends R> combiner,
boolean delayErrors)
Returns a Flowable that emits the results of a specified function to the pair of values emitted by the
source Publisher and a specified collection Publisher.
|
<U,R> Flowable<R> |
Flowable.flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends U>> mapper,
BiFunction<? super T,? super U,? extends R> combiner,
boolean delayErrors,
int maxConcurrency)
Returns a Flowable that emits the results of a specified function to the pair of values emitted by the
source Publisher and a specified collection Publisher, while limiting the maximum number of concurrent
subscriptions to these Publishers.
|
<U,R> Flowable<R> |
Flowable.flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends U>> mapper,
BiFunction<? super T,? super U,? extends R> combiner,
boolean delayErrors,
int maxConcurrency,
int bufferSize)
Returns a Flowable that emits the results of a specified function to the pair of values emitted by the
source Publisher and a specified collection Publisher, while limiting the maximum number of concurrent
subscriptions to these Publishers.
|
<U,R> Flowable<R> |
Flowable.flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends U>> mapper,
BiFunction<? super T,? super U,? extends R> combiner,
int maxConcurrency)
Returns a Flowable that emits the results of a specified function to the pair of values emitted by the
source Publisher and a specified collection Publisher, while limiting the maximum number of concurrent
subscriptions to these Publishers.
|
<R> Single<R> |
Single.flatMap(Function<? super T,? extends SingleSource<? extends R>> mapper)
Returns a Single that is based on applying a specified function to the item emitted by the source Single,
where that function returns a SingleSource.
|
Completable |
Single.flatMapCompletable(Function<? super T,? extends CompletableSource> mapper)
Returns a
Completable that completes based on applying a specified function to the item emitted by the
source Single , where that function returns a Completable . |
Completable |
Observable.flatMapCompletable(Function<? super T,? extends CompletableSource> mapper)
Maps each element of the upstream Observable into CompletableSources, subscribes to them and
waits until the upstream and all CompletableSources complete.
|
Completable |
Maybe.flatMapCompletable(Function<? super T,? extends CompletableSource> mapper)
Returns a
Completable that completes based on applying a specified function to the item emitted by the
source Maybe , where that function returns a Completable . |
Completable |
Flowable.flatMapCompletable(Function<? super T,? extends CompletableSource> mapper)
Maps each element of the upstream Flowable into CompletableSources, subscribes to them and
waits until the upstream and all CompletableSources complete.
|
Completable |
Observable.flatMapCompletable(Function<? super T,? extends CompletableSource> mapper,
boolean delayErrors)
Maps each element of the upstream Observable into CompletableSources, subscribes to them and
waits until the upstream and all CompletableSources complete, optionally delaying all errors.
|
Completable |
Flowable.flatMapCompletable(Function<? super T,? extends CompletableSource> mapper,
boolean delayErrors,
int maxConcurrency)
Maps each element of the upstream Flowable into CompletableSources, subscribes to them and
waits until the upstream and all CompletableSources complete, optionally delaying all errors.
|
<U> Observable<U> |
Observable.flatMapIterable(Function<? super T,? extends Iterable<? extends U>> mapper)
Returns an Observable that merges each item emitted by the source ObservableSource with the values in an
Iterable corresponding to that item that is generated by a selector.
|
<U> Flowable<U> |
Flowable.flatMapIterable(Function<? super T,? extends Iterable<? extends U>> mapper)
Returns a Flowable that merges each item emitted by the source Publisher with the values in an
Iterable corresponding to that item that is generated by a selector.
|
<U,V> Observable<V> |
Observable.flatMapIterable(Function<? super T,? extends Iterable<? extends U>> mapper,
BiFunction<? super T,? super U,? extends V> resultSelector)
Returns an Observable that emits the results of applying a function to the pair of values from the source
ObservableSource and an Iterable corresponding to that item that is generated by a selector.
|
<U,V> Flowable<V> |
Flowable.flatMapIterable(Function<? super T,? extends Iterable<? extends U>> mapper,
BiFunction<? super T,? super U,? extends V> resultSelector)
Returns a Flowable that emits the results of applying a function to the pair of values from the source
Publisher and an Iterable corresponding to that item that is generated by a selector.
|
<U,V> Flowable<V> |
Flowable.flatMapIterable(Function<? super T,? extends Iterable<? extends U>> mapper,
BiFunction<? super T,? super U,? extends V> resultSelector,
int prefetch)
Returns a Flowable that merges each item emitted by the source Publisher with the values in an
Iterable corresponding to that item that is generated by a selector, while limiting the number of concurrent
subscriptions to these Publishers.
|
<U> Flowable<U> |
Flowable.flatMapIterable(Function<? super T,? extends Iterable<? extends U>> mapper,
int bufferSize)
Returns a Flowable that merges each item emitted by the source Publisher with the values in an
Iterable corresponding to that item that is generated by a selector.
|
<R> Maybe<R> |
Single.flatMapMaybe(Function<? super T,? extends MaybeSource<? extends R>> mapper)
Returns a Maybe that is based on applying a specified function to the item emitted by the source Single,
where that function returns a MaybeSource.
|
<R> Observable<R> |
Observable.flatMapMaybe(Function<? super T,? extends MaybeSource<? extends R>> mapper)
Maps each element of the upstream Observable into MaybeSources, subscribes to all of them
and merges their onSuccess values, in no particular order, into a single Observable sequence.
|
<R> Flowable<R> |
Flowable.flatMapMaybe(Function<? super T,? extends MaybeSource<? extends R>> mapper)
Maps each element of the upstream Flowable into MaybeSources, subscribes to all of them
and merges their onSuccess values, in no particular order, into a single Flowable sequence.
|
<R> Observable<R> |
Observable.flatMapMaybe(Function<? super T,? extends MaybeSource<? extends R>> mapper,
boolean delayErrors)
Maps each element of the upstream Observable into MaybeSources, subscribes to them
and merges their onSuccess values, in no particular order, into a single Observable sequence,
optionally delaying all errors.
|
<R> Flowable<R> |
Flowable.flatMapMaybe(Function<? super T,? extends MaybeSource<? extends R>> mapper,
boolean delayErrors,
int maxConcurrency)
Maps each element of the upstream Flowable into MaybeSources, subscribes to at most
maxConcurrency MaybeSources at a time and merges their onSuccess values,
in no particular order, into a single Flowable sequence, optionally delaying all errors. |
<R> Observable<R> |
Single.flatMapObservable(Function<? super T,? extends ObservableSource<? extends R>> mapper)
Returns an Observable that is based on applying a specified function to the item emitted by the source Single,
where that function returns an ObservableSource.
|
<R> Observable<R> |
Maybe.flatMapObservable(Function<? super T,? extends ObservableSource<? extends R>> mapper)
Returns an Observable that is based on applying a specified function to the item emitted by the source Maybe,
where that function returns an ObservableSource.
|
<R> Flowable<R> |
Single.flatMapPublisher(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper)
Returns a Flowable that emits items based on applying a specified function to the item emitted by the
source Single, where that function returns a Publisher.
|
<R> Flowable<R> |
Maybe.flatMapPublisher(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper)
Returns a Flowable that emits items based on applying a specified function to the item emitted by the
source Maybe, where that function returns a Publisher.
|
<R> Observable<R> |
Observable.flatMapSingle(Function<? super T,? extends SingleSource<? extends R>> mapper)
Maps each element of the upstream Observable into SingleSources, subscribes to all of them
and merges their onSuccess values, in no particular order, into a single Observable sequence.
|
<R> Single<R> |
Maybe.flatMapSingle(Function<? super T,? extends SingleSource<? extends R>> mapper)
|
<R> Flowable<R> |
Flowable.flatMapSingle(Function<? super T,? extends SingleSource<? extends R>> mapper)
Maps each element of the upstream Flowable into SingleSources, subscribes to all of them
and merges their onSuccess values, in no particular order, into a single Flowable sequence.
|
<R> Observable<R> |
Observable.flatMapSingle(Function<? super T,? extends SingleSource<? extends R>> mapper,
boolean delayErrors)
Maps each element of the upstream Observable into SingleSources, subscribes to them
and merges their onSuccess values, in no particular order, into a single Observable sequence,
optionally delaying all errors.
|
<R> Flowable<R> |
Flowable.flatMapSingle(Function<? super T,? extends SingleSource<? extends R>> mapper,
boolean delayErrors,
int maxConcurrency)
Maps each element of the upstream Flowable into SingleSources, subscribes to at most
maxConcurrency SingleSources at a time and merges their onSuccess values,
in no particular order, into a single Flowable sequence, optionally delaying all errors. |
<R> Maybe<R> |
Maybe.flatMapSingleElement(Function<? super T,? extends SingleSource<? extends R>> mapper)
|
<U> Flowable<U> |
Single.flattenAsFlowable(Function<? super T,? extends Iterable<? extends U>> mapper)
Returns a Flowable that merges each item emitted by the source Single with the values in an
Iterable corresponding to that item that is generated by a selector.
|
<U> Flowable<U> |
Maybe.flattenAsFlowable(Function<? super T,? extends Iterable<? extends U>> mapper)
Returns a Flowable that merges each item emitted by the source Maybe with the values in an
Iterable corresponding to that item that is generated by a selector.
|
<U> Observable<U> |
Single.flattenAsObservable(Function<? super T,? extends Iterable<? extends U>> mapper)
Returns an Observable that maps a success value into an Iterable and emits its items.
|
<U> Observable<U> |
Maybe.flattenAsObservable(Function<? super T,? extends Iterable<? extends U>> mapper)
Returns an Observable that maps a success value into an Iterable and emits its items.
|
<K> Observable<GroupedObservable<K,T>> |
Observable.groupBy(Function<? super T,? extends K> keySelector)
Groups the items emitted by an
ObservableSource according to a specified criterion, and emits these
grouped items as GroupedObservable s. |
<K> Flowable<GroupedFlowable<K,T>> |
Flowable.groupBy(Function<? super T,? extends K> keySelector)
Groups the items emitted by a
Publisher according to a specified criterion, and emits these
grouped items as GroupedFlowable s. |
<K> Observable<GroupedObservable<K,T>> |
Observable.groupBy(Function<? super T,? extends K> keySelector,
boolean delayError)
Groups the items emitted by an
ObservableSource according to a specified criterion, and emits these
grouped items as GroupedObservable s. |
<K> Flowable<GroupedFlowable<K,T>> |
Flowable.groupBy(Function<? super T,? extends K> keySelector,
boolean delayError)
Groups the items emitted by a
Publisher according to a specified criterion, and emits these
grouped items as GroupedFlowable s. |
<K,V> Observable<GroupedObservable<K,V>> |
Observable.groupBy(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector)
Groups the items emitted by an
ObservableSource according to a specified criterion, and emits these
grouped items as GroupedObservable s. |
<K,V> Observable<GroupedObservable<K,V>> |
Observable.groupBy(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector)
Groups the items emitted by an
ObservableSource according to a specified criterion, and emits these
grouped items as GroupedObservable s. |
<K,V> Flowable<GroupedFlowable<K,V>> |
Flowable.groupBy(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector)
Groups the items emitted by a
Publisher according to a specified criterion, and emits these
grouped items as GroupedFlowable s. |
<K,V> Flowable<GroupedFlowable<K,V>> |
Flowable.groupBy(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector)
Groups the items emitted by a
Publisher according to a specified criterion, and emits these
grouped items as GroupedFlowable s. |
<K,V> Observable<GroupedObservable<K,V>> |
Observable.groupBy(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
boolean delayError)
Groups the items emitted by an
ObservableSource according to a specified criterion, and emits these
grouped items as GroupedObservable s. |
<K,V> Observable<GroupedObservable<K,V>> |
Observable.groupBy(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
boolean delayError)
Groups the items emitted by an
ObservableSource according to a specified criterion, and emits these
grouped items as GroupedObservable s. |
<K,V> Flowable<GroupedFlowable<K,V>> |
Flowable.groupBy(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
boolean delayError)
Groups the items emitted by a
Publisher according to a specified criterion, and emits these
grouped items as GroupedFlowable s. |
<K,V> Flowable<GroupedFlowable<K,V>> |
Flowable.groupBy(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
boolean delayError)
Groups the items emitted by a
Publisher according to a specified criterion, and emits these
grouped items as GroupedFlowable s. |
<K,V> Observable<GroupedObservable<K,V>> |
Observable.groupBy(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
boolean delayError,
int bufferSize)
Groups the items emitted by an
ObservableSource according to a specified criterion, and emits these
grouped items as GroupedObservable s. |
<K,V> Observable<GroupedObservable<K,V>> |
Observable.groupBy(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
boolean delayError,
int bufferSize)
Groups the items emitted by an
ObservableSource according to a specified criterion, and emits these
grouped items as GroupedObservable s. |
<K,V> Flowable<GroupedFlowable<K,V>> |
Flowable.groupBy(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
boolean delayError,
int bufferSize)
Groups the items emitted by a
Publisher according to a specified criterion, and emits these
grouped items as GroupedFlowable s. |
<K,V> Flowable<GroupedFlowable<K,V>> |
Flowable.groupBy(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
boolean delayError,
int bufferSize)
Groups the items emitted by a
Publisher according to a specified criterion, and emits these
grouped items as GroupedFlowable s. |
<K,V> Flowable<GroupedFlowable<K,V>> |
Flowable.groupBy(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
boolean delayError,
int bufferSize,
Function<? super Consumer<Object>,? extends Map<K,Object>> evictingMapFactory)
Groups the items emitted by a
Publisher according to a specified criterion, and emits these
grouped items as GroupedFlowable s. |
<K,V> Flowable<GroupedFlowable<K,V>> |
Flowable.groupBy(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
boolean delayError,
int bufferSize,
Function<? super Consumer<Object>,? extends Map<K,Object>> evictingMapFactory)
Groups the items emitted by a
Publisher according to a specified criterion, and emits these
grouped items as GroupedFlowable s. |
<K,V> Flowable<GroupedFlowable<K,V>> |
Flowable.groupBy(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
boolean delayError,
int bufferSize,
Function<? super Consumer<Object>,? extends Map<K,Object>> evictingMapFactory)
Groups the items emitted by a
Publisher according to a specified criterion, and emits these
grouped items as GroupedFlowable s. |
<TRight,TLeftEnd,TRightEnd,R> |
Observable.groupJoin(ObservableSource<? extends TRight> other,
Function<? super T,? extends ObservableSource<TLeftEnd>> leftEnd,
Function<? super TRight,? extends ObservableSource<TRightEnd>> rightEnd,
BiFunction<? super T,? super Observable<TRight>,? extends R> resultSelector)
Returns an Observable that correlates two ObservableSources when they overlap in time and groups the results.
|
<TRight,TLeftEnd,TRightEnd,R> |
Observable.groupJoin(ObservableSource<? extends TRight> other,
Function<? super T,? extends ObservableSource<TLeftEnd>> leftEnd,
Function<? super TRight,? extends ObservableSource<TRightEnd>> rightEnd,
BiFunction<? super T,? super Observable<TRight>,? extends R> resultSelector)
Returns an Observable that correlates two ObservableSources when they overlap in time and groups the results.
|
<TRight,TLeftEnd,TRightEnd,R> |
Flowable.groupJoin(org.reactivestreams.Publisher<? extends TRight> other,
Function<? super T,? extends org.reactivestreams.Publisher<TLeftEnd>> leftEnd,
Function<? super TRight,? extends org.reactivestreams.Publisher<TRightEnd>> rightEnd,
BiFunction<? super T,? super Flowable<TRight>,? extends R> resultSelector)
Returns a Flowable that correlates two Publishers when they overlap in time and groups the results.
|
<TRight,TLeftEnd,TRightEnd,R> |
Flowable.groupJoin(org.reactivestreams.Publisher<? extends TRight> other,
Function<? super T,? extends org.reactivestreams.Publisher<TLeftEnd>> leftEnd,
Function<? super TRight,? extends org.reactivestreams.Publisher<TRightEnd>> rightEnd,
BiFunction<? super T,? super Flowable<TRight>,? extends R> resultSelector)
Returns a Flowable that correlates two Publishers when they overlap in time and groups the results.
|
<TRight,TLeftEnd,TRightEnd,R> |
Observable.join(ObservableSource<? extends TRight> other,
Function<? super T,? extends ObservableSource<TLeftEnd>> leftEnd,
Function<? super TRight,? extends ObservableSource<TRightEnd>> rightEnd,
BiFunction<? super T,? super TRight,? extends R> resultSelector)
Correlates the items emitted by two ObservableSources based on overlapping durations.
|
<TRight,TLeftEnd,TRightEnd,R> |
Observable.join(ObservableSource<? extends TRight> other,
Function<? super T,? extends ObservableSource<TLeftEnd>> leftEnd,
Function<? super TRight,? extends ObservableSource<TRightEnd>> rightEnd,
BiFunction<? super T,? super TRight,? extends R> resultSelector)
Correlates the items emitted by two ObservableSources based on overlapping durations.
|
<TRight,TLeftEnd,TRightEnd,R> |
Flowable.join(org.reactivestreams.Publisher<? extends TRight> other,
Function<? super T,? extends org.reactivestreams.Publisher<TLeftEnd>> leftEnd,
Function<? super TRight,? extends org.reactivestreams.Publisher<TRightEnd>> rightEnd,
BiFunction<? super T,? super TRight,? extends R> resultSelector)
Correlates the items emitted by two Publishers based on overlapping durations.
|
<TRight,TLeftEnd,TRightEnd,R> |
Flowable.join(org.reactivestreams.Publisher<? extends TRight> other,
Function<? super T,? extends org.reactivestreams.Publisher<TLeftEnd>> leftEnd,
Function<? super TRight,? extends org.reactivestreams.Publisher<TRightEnd>> rightEnd,
BiFunction<? super T,? super TRight,? extends R> resultSelector)
Correlates the items emitted by two Publishers based on overlapping durations.
|
<R> Single<R> |
Single.map(Function<? super T,? extends R> mapper)
Returns a Single that applies a specified function to the item emitted by the source Single and
emits the result of this function application.
|
<R> Observable<R> |
Observable.map(Function<? super T,? extends R> mapper)
Returns an Observable that applies a specified function to each item emitted by the source ObservableSource and
emits the results of these function applications.
|
<R> Maybe<R> |
Maybe.map(Function<? super T,? extends R> mapper)
Returns a Maybe that applies a specified function to the item emitted by the source Maybe and
emits the result of this function application.
|
<R> Flowable<R> |
Flowable.map(Function<? super T,? extends R> mapper)
Returns a Flowable that applies a specified function to each item emitted by the source Publisher and
emits the results of these function applications.
|
Completable |
Completable.onErrorResumeNext(Function<? super Throwable,? extends CompletableSource> errorMapper)
Returns a Completable instance that when encounters an error from this Completable, calls the
specified mapper function that returns another Completable instance for it and resumes the
execution with it.
|
Maybe<T> |
Maybe.onErrorResumeNext(Function<? super Throwable,? extends MaybeSource<? extends T>> resumeFunction)
Instructs a Maybe to pass control to another Maybe rather than invoking
onError if it encounters an error. |
Observable<T> |
Observable.onErrorResumeNext(Function<? super Throwable,? extends ObservableSource<? extends T>> resumeFunction)
Instructs an ObservableSource to pass control to another ObservableSource rather than invoking
onError if it encounters an error. |
Flowable<T> |
Flowable.onErrorResumeNext(Function<? super Throwable,? extends org.reactivestreams.Publisher<? extends T>> resumeFunction)
Instructs a Publisher to pass control to another Publisher rather than invoking
onError if it encounters an error. |
Single<T> |
Single.onErrorResumeNext(Function<? super Throwable,? extends SingleSource<? extends T>> resumeFunctionInCaseOfError)
Instructs a Single to pass control to another Single rather than invoking
SingleObserver.onError(Throwable) if it encounters an error. |
Observable<T> |
Observable.onErrorReturn(Function<? super Throwable,? extends T> valueSupplier)
Instructs an ObservableSource to emit an item (returned by a specified function) rather than invoking
onError if it encounters an error. |
Maybe<T> |
Maybe.onErrorReturn(Function<? super Throwable,? extends T> valueSupplier)
Instructs a Maybe to emit an item (returned by a specified function) rather than invoking
onError if it encounters an error. |
Flowable<T> |
Flowable.onErrorReturn(Function<? super Throwable,? extends T> valueSupplier)
Instructs a Publisher to emit an item (returned by a specified function) rather than invoking
onError if it encounters an error. |
Single<T> |
Single.onErrorReturn(Function<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. |
<R> Flowable<R> |
Flowable.publish(Function<? super Flowable<T>,? extends org.reactivestreams.Publisher<? extends R>> selector,
int prefetch)
Returns a Flowable that emits the results of invoking a specified selector on items emitted by a
ConnectableFlowable that shares a single subscription to the underlying sequence. |
<R> Flowable<R> |
Flowable.publish(Function<? super Flowable<T>,? extends org.reactivestreams.Publisher<R>> selector)
Returns a Flowable that emits the results of invoking a specified selector on items emitted by a
ConnectableFlowable that shares a single subscription to the underlying sequence. |
<R> Observable<R> |
Observable.publish(Function<? super Observable<T>,? extends ObservableSource<R>> selector)
Returns an Observable that emits the results of invoking a specified selector on items emitted by a
ConnectableObservable that shares a single subscription to the underlying sequence. |
Flowable<T> |
Single.repeatWhen(Function<? super Flowable<Object>,? extends org.reactivestreams.Publisher<?>> handler)
Re-subscribes to the current Single if
the Publisher returned by the handler function signals a value in response to a
value signalled through the Flowable the handle receives.
|
Flowable<T> |
Maybe.repeatWhen(Function<? super Flowable<Object>,? extends org.reactivestreams.Publisher<?>> handler)
Returns a Flowable that emits the same values as the source Publisher with the exception of an
onComplete . |
Flowable<T> |
Flowable.repeatWhen(Function<? super Flowable<Object>,? extends org.reactivestreams.Publisher<?>> handler)
Returns a Flowable that emits the same values as the source Publisher with the exception of an
onComplete . |
Completable |
Completable.repeatWhen(Function<? super Flowable<Object>,? extends org.reactivestreams.Publisher<?>> handler)
Returns a Completable instance that repeats when the Publisher returned by the handler
emits an item or completes when this Publisher emits a completed event.
|
Observable<T> |
Observable.repeatWhen(Function<? super Observable<Object>,? extends ObservableSource<?>> handler)
Returns an Observable that emits the same values as the source ObservableSource with the exception of an
onComplete . |
<R> Flowable<R> |
Flowable.replay(Function<? super Flowable<T>,? extends org.reactivestreams.Publisher<R>> selector)
Returns a Flowable that emits items that are the results of invoking a specified selector on the items
emitted by a
ConnectableFlowable that shares a single subscription to the source Publisher. |
<R> Flowable<R> |
Flowable.replay(Function<? super Flowable<T>,? extends org.reactivestreams.Publisher<R>> selector,
int bufferSize)
Returns a Flowable that emits items that are the results of invoking a specified selector on items
emitted by a
ConnectableFlowable that shares a single subscription to the source Publisher,
replaying bufferSize notifications. |
<R> Flowable<R> |
Flowable.replay(Function<? super Flowable<T>,? extends org.reactivestreams.Publisher<R>> selector,
int bufferSize,
long time,
TimeUnit unit)
Returns a Flowable that emits items that are the results of invoking a specified selector on items
emitted by a
ConnectableFlowable that shares a single subscription to the source Publisher,
replaying no more than bufferSize items that were emitted within a specified time window. |
<R> Flowable<R> |
Flowable.replay(Function<? super Flowable<T>,? extends org.reactivestreams.Publisher<R>> selector,
int bufferSize,
long time,
TimeUnit unit,
Scheduler scheduler)
Returns a Flowable that emits items that are the results of invoking a specified selector on items
emitted by a
ConnectableFlowable that shares a single subscription to the source Publisher,
replaying no more than bufferSize items that were emitted within a specified time window. |
<R> Flowable<R> |
Flowable.replay(Function<? super Flowable<T>,? extends org.reactivestreams.Publisher<R>> selector,
int bufferSize,
Scheduler scheduler)
Returns a Flowable that emits items that are the results of invoking a specified selector on items
emitted by a
ConnectableFlowable that shares a single subscription to the source Publisher,
replaying a maximum of bufferSize items. |
<R> Flowable<R> |
Flowable.replay(Function<? super Flowable<T>,? extends org.reactivestreams.Publisher<R>> selector,
long time,
TimeUnit unit)
Returns a Flowable that emits items that are the results of invoking a specified selector on items
emitted by a
ConnectableFlowable that shares a single subscription to the source Publisher,
replaying all items that were emitted within a specified time window. |
<R> Flowable<R> |
Flowable.replay(Function<? super Flowable<T>,? extends org.reactivestreams.Publisher<R>> selector,
long time,
TimeUnit unit,
Scheduler scheduler)
Returns a Flowable that emits items that are the results of invoking a specified selector on items
emitted by a
ConnectableFlowable that shares a single subscription to the source Publisher,
replaying all items that were emitted within a specified time window. |
<R> Flowable<R> |
Flowable.replay(Function<? super Flowable<T>,? extends org.reactivestreams.Publisher<R>> selector,
Scheduler scheduler)
Returns a Flowable that emits items that are the results of invoking a specified selector on items
emitted by a
ConnectableFlowable that shares a single subscription to the source Publisher. |
<R> Observable<R> |
Observable.replay(Function<? super Observable<T>,? extends ObservableSource<R>> selector)
Returns an Observable that emits items that are the results of invoking a specified selector on the items
emitted by a
ConnectableObservable that shares a single subscription to the source ObservableSource. |
<R> Observable<R> |
Observable.replay(Function<? super Observable<T>,? extends ObservableSource<R>> selector,
int bufferSize)
Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a
ConnectableObservable that shares a single subscription to the source ObservableSource,
replaying bufferSize notifications. |
<R> Observable<R> |
Observable.replay(Function<? super Observable<T>,? extends ObservableSource<R>> selector,
int bufferSize,
long time,
TimeUnit unit)
Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a
ConnectableObservable that shares a single subscription to the source ObservableSource,
replaying no more than bufferSize items that were emitted within a specified time window. |
<R> Observable<R> |
Observable.replay(Function<? super Observable<T>,? extends ObservableSource<R>> selector,
int bufferSize,
long time,
TimeUnit unit,
Scheduler scheduler)
Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a
ConnectableObservable that shares a single subscription to the source ObservableSource,
replaying no more than bufferSize items that were emitted within a specified time window. |
<R> Observable<R> |
Observable.replay(Function<? super Observable<T>,? extends ObservableSource<R>> selector,
int bufferSize,
Scheduler scheduler)
Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a
ConnectableObservable that shares a single subscription to the source ObservableSource,
replaying a maximum of bufferSize items. |
<R> Observable<R> |
Observable.replay(Function<? super Observable<T>,? extends ObservableSource<R>> selector,
long time,
TimeUnit unit)
Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a
ConnectableObservable that shares a single subscription to the source ObservableSource,
replaying all items that were emitted within a specified time window. |
<R> Observable<R> |
Observable.replay(Function<? super Observable<T>,? extends ObservableSource<R>> selector,
long time,
TimeUnit unit,
Scheduler scheduler)
Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a
ConnectableObservable that shares a single subscription to the source ObservableSource,
replaying all items that were emitted within a specified time window. |
<R> Observable<R> |
Observable.replay(Function<? super Observable<T>,? extends ObservableSource<R>> selector,
Scheduler scheduler)
Returns an Observable that emits items that are the results of invoking a specified selector on items
emitted by a
ConnectableObservable that shares a single subscription to the source ObservableSource. |
Single<T> |
Single.retryWhen(Function<? super Flowable<Throwable>,? extends org.reactivestreams.Publisher<?>> handler)
Re-subscribes to the current Single if and when the Publisher returned by the handler
function signals a value.
|
Maybe<T> |
Maybe.retryWhen(Function<? super Flowable<Throwable>,? extends org.reactivestreams.Publisher<?>> handler)
Returns a Maybe that emits the same values as the source Maybe with the exception of an
onError . |
Flowable<T> |
Flowable.retryWhen(Function<? super Flowable<Throwable>,? extends org.reactivestreams.Publisher<?>> handler)
Returns a Flowable that emits the same values as the source Publisher with the exception of an
onError . |
Completable |
Completable.retryWhen(Function<? super Flowable<Throwable>,? extends org.reactivestreams.Publisher<?>> handler)
Returns a Completable which given a Publisher and when this Completable emits an error, delivers
that error through a Flowable and the Publisher should signal a value indicating a retry in response
or a terminal event indicating a termination.
|
Observable<T> |
Observable.retryWhen(Function<? super Observable<Throwable>,? extends ObservableSource<?>> handler)
Returns an Observable that emits the same values as the source ObservableSource with the exception of an
onError . |
<R> Observable<R> |
Observable.switchMap(Function<? super T,? extends ObservableSource<? extends R>> mapper)
Returns a new ObservableSource by applying a function that you supply to each item emitted by the source
ObservableSource that returns an ObservableSource, and then emitting the items emitted by the most recently emitted
of these ObservableSources.
|
<R> Observable<R> |
Observable.switchMap(Function<? super T,? extends ObservableSource<? extends R>> mapper,
int bufferSize)
Returns a new ObservableSource by applying a function that you supply to each item emitted by the source
ObservableSource that returns an ObservableSource, and then emitting the items emitted by the most recently emitted
of these ObservableSources.
|
<R> Flowable<R> |
Flowable.switchMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper)
Returns a new Publisher by applying a function that you supply to each item emitted by the source
Publisher that returns a Publisher, and then emitting the items emitted by the most recently emitted
of these Publishers.
|
<R> Flowable<R> |
Flowable.switchMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
int bufferSize)
Returns a new Publisher by applying a function that you supply to each item emitted by the source
Publisher that returns a Publisher, and then emitting the items emitted by the most recently emitted
of these Publishers.
|
Completable |
Observable.switchMapCompletable(Function<? super T,? extends CompletableSource> mapper)
Maps the upstream values into
CompletableSource s, subscribes to the newer one while
disposing the subscription to the previous CompletableSource , thus keeping at most one
active CompletableSource running. |
Completable |
Flowable.switchMapCompletable(Function<? super T,? extends CompletableSource> mapper)
Maps the upstream values into
CompletableSource s, subscribes to the newer one while
disposing the subscription to the previous CompletableSource , thus keeping at most one
active CompletableSource running. |
Completable |
Observable.switchMapCompletableDelayError(Function<? super T,? extends CompletableSource> mapper)
Maps the upstream values into
CompletableSource s, subscribes to the newer one while
disposing the subscription to the previous CompletableSource , thus keeping at most one
active CompletableSource running and delaying any main or inner errors until all
of them terminate. |
Completable |
Flowable.switchMapCompletableDelayError(Function<? super T,? extends CompletableSource> mapper)
Maps the upstream values into
CompletableSource s, subscribes to the newer one while
disposing the subscription to the previous CompletableSource , thus keeping at most one
active CompletableSource running and delaying any main or inner errors until all
of them terminate. |
<R> Observable<R> |
Observable.switchMapDelayError(Function<? super T,? extends ObservableSource<? extends R>> mapper)
Returns a new ObservableSource by applying a function that you supply to each item emitted by the source
ObservableSource that returns an ObservableSource, and then emitting the items emitted by the most recently emitted
of these ObservableSources and delays any error until all ObservableSources terminate.
|
<R> Observable<R> |
Observable.switchMapDelayError(Function<? super T,? extends ObservableSource<? extends R>> mapper,
int bufferSize)
Returns a new ObservableSource by applying a function that you supply to each item emitted by the source
ObservableSource that returns an ObservableSource, and then emitting the items emitted by the most recently emitted
of these ObservableSources and delays any error until all ObservableSources terminate.
|
<R> Flowable<R> |
Flowable.switchMapDelayError(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper)
Returns a new Publisher by applying a function that you supply to each item emitted by the source
Publisher that returns a Publisher, and then emitting the items emitted by the most recently emitted
of these Publishers and delays any error until all Publishers terminate.
|
<R> Flowable<R> |
Flowable.switchMapDelayError(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
int bufferSize)
Returns a new Publisher by applying a function that you supply to each item emitted by the source
Publisher that returns a Publisher, and then emitting the items emitted by the most recently emitted
of these Publishers and delays any error until all Publishers terminate.
|
<R> Observable<R> |
Observable.switchMapMaybe(Function<? super T,? extends MaybeSource<? extends R>> mapper)
Maps the upstream items into
MaybeSource s and switches (subscribes) to the newer ones
while disposing the older ones (and ignoring their signals) and emits the latest success value of the current one if
available while failing immediately if this Observable or any of the
active inner MaybeSource s fail. |
<R> Flowable<R> |
Flowable.switchMapMaybe(Function<? super T,? extends MaybeSource<? extends R>> mapper)
Maps the upstream items into
MaybeSource s and switches (subscribes) to the newer ones
while disposing the older ones (and ignoring their signals) and emits the latest success value of the current one if
available while failing immediately if this Flowable or any of the
active inner MaybeSource s fail. |
<R> Observable<R> |
Observable.switchMapMaybeDelayError(Function<? super T,? extends MaybeSource<? extends R>> mapper)
Maps the upstream items into
MaybeSource s and switches (subscribes) to the newer ones
while disposing the older ones (and ignoring their signals) and emits the latest success value of the current one if
available, delaying errors from this Observable or the inner MaybeSource s until all terminate. |
<R> Flowable<R> |
Flowable.switchMapMaybeDelayError(Function<? super T,? extends MaybeSource<? extends R>> mapper)
Maps the upstream items into
MaybeSource s and switches (subscribes) to the newer ones
while disposing the older ones (and ignoring their signals) and emits the latest success value of the current one if
available, delaying errors from this Flowable or the inner MaybeSource s until all terminate. |
<R> Observable<R> |
Observable.switchMapSingle(Function<? super T,? extends SingleSource<? extends R>> mapper)
Returns a new ObservableSource by applying a function that you supply to each item emitted by the source
ObservableSource that returns a SingleSource, and then emitting the item emitted by the most recently emitted
of these SingleSources.
|
<R> Flowable<R> |
Flowable.switchMapSingle(Function<? super T,? extends SingleSource<? extends R>> mapper)
Maps the upstream items into
SingleSource s and switches (subscribes) to the newer ones
while disposing the older ones (and ignoring their signals) and emits the latest success value of the current one
while failing immediately if this Flowable or any of the
active inner SingleSource s fail. |
<R> Observable<R> |
Observable.switchMapSingleDelayError(Function<? super T,? extends SingleSource<? extends R>> mapper)
Returns a new ObservableSource by applying a function that you supply to each item emitted by the source
ObservableSource that returns a SingleSource, and then emitting the item emitted by the most recently emitted
of these SingleSources and delays any error until all SingleSources terminate.
|
<R> Flowable<R> |
Flowable.switchMapSingleDelayError(Function<? super T,? extends SingleSource<? extends R>> mapper)
Maps the upstream items into
SingleSource s and switches (subscribes) to the newer ones
while disposing the older ones (and ignoring their signals) and emits the latest success value of the current one,
delaying errors from this Flowable or the inner SingleSource s until all terminate. |
<V> Observable<T> |
Observable.timeout(Function<? super T,? extends ObservableSource<V>> itemTimeoutIndicator)
Returns an Observable that mirrors the source ObservableSource, but notifies observers of a
TimeoutException if an item emitted by the source ObservableSource doesn't arrive within a window of
time after the emission of the previous item, where that period of time is measured by an ObservableSource that
is a function of the previous item. |
<V> Observable<T> |
Observable.timeout(Function<? super T,? extends ObservableSource<V>> itemTimeoutIndicator,
ObservableSource<? extends T> other)
Returns an Observable that mirrors the source ObservableSource, but that switches to a fallback ObservableSource if
an item emitted by the source ObservableSource doesn't arrive within a window of time after the emission of the
previous item, where that period of time is measured by an ObservableSource that is a function of the previous
item.
|
<V> Flowable<T> |
Flowable.timeout(Function<? super T,? extends org.reactivestreams.Publisher<V>> itemTimeoutIndicator)
Returns a Flowable that mirrors the source Publisher, but notifies Subscribers of a
TimeoutException if an item emitted by the source Publisher doesn't arrive within a window of
time after the emission of the previous item, where that period of time is measured by a Publisher that
is a function of the previous item. |
<V> Flowable<T> |
Flowable.timeout(Function<? super T,? extends org.reactivestreams.Publisher<V>> itemTimeoutIndicator,
Flowable<? extends T> other)
Returns a Flowable that mirrors the source Publisher, but that switches to a fallback Publisher if
an item emitted by the source Publisher doesn't arrive within a window of time after the emission of the
previous item, where that period of time is measured by a Publisher that is a function of the previous
item.
|
<U,V> Observable<T> |
Observable.timeout(ObservableSource<U> firstTimeoutIndicator,
Function<? super T,? extends ObservableSource<V>> itemTimeoutIndicator)
Returns an Observable that mirrors the source ObservableSource, but notifies observers of a
TimeoutException if either the first item emitted by the source ObservableSource or any subsequent item
doesn't arrive within time windows defined by other ObservableSources. |
<U,V> Observable<T> |
Observable.timeout(ObservableSource<U> firstTimeoutIndicator,
Function<? super T,? extends ObservableSource<V>> itemTimeoutIndicator,
ObservableSource<? extends T> other)
Returns an Observable that mirrors the source ObservableSource, but switches to a fallback ObservableSource if either
the first item emitted by the source ObservableSource or any subsequent item doesn't arrive within time windows
defined by other ObservableSources.
|
<U,V> Flowable<T> |
Flowable.timeout(org.reactivestreams.Publisher<U> firstTimeoutIndicator,
Function<? super T,? extends org.reactivestreams.Publisher<V>> itemTimeoutIndicator)
Returns a Flowable that mirrors the source Publisher, but notifies Subscribers of a
TimeoutException if either the first item emitted by the source Publisher or any subsequent item
doesn't arrive within time windows defined by other Publishers. |
<U,V> Flowable<T> |
Flowable.timeout(org.reactivestreams.Publisher<U> firstTimeoutIndicator,
Function<? super T,? extends org.reactivestreams.Publisher<V>> itemTimeoutIndicator,
org.reactivestreams.Publisher<? extends T> other)
Returns a Flowable that mirrors the source Publisher, but switches to a fallback Publisher if either
the first item emitted by the source Publisher or any subsequent item doesn't arrive within time windows
defined by other Publishers.
|
<U> U |
Completable.to(Function<? super Completable,U> converter)
Allows fluent conversion to another type via a function callback.
|
<R> R |
Flowable.to(Function<? super Flowable<T>,R> converter)
Calls the specified converter function during assembly time and returns its resulting value.
|
<R> R |
Maybe.to(Function<? super Maybe<T>,R> convert)
Calls the specified converter function with the current Maybe instance
during assembly time and returns its result.
|
<R> R |
Observable.to(Function<? super Observable<T>,R> converter)
Calls the specified converter function during assembly time and returns its resulting value.
|
<R> R |
Single.to(Function<? super Single<T>,R> convert)
Calls the specified converter function with the current Single instance
during assembly time and returns its result.
|
<K> Single<Map<K,T>> |
Observable.toMap(Function<? super T,? extends K> keySelector)
Returns a Single that emits a single HashMap containing all items emitted by the
finite source ObservableSource, mapped by the keys returned by a specified
keySelector function. |
<K> Single<Map<K,T>> |
Flowable.toMap(Function<? super T,? extends K> keySelector)
Returns a Single that emits a single HashMap containing all items emitted by the finite source Publisher,
mapped by the keys returned by a specified
keySelector function. |
<K,V> Single<Map<K,V>> |
Observable.toMap(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector)
Returns a Single that emits a single HashMap containing values corresponding to items emitted by the
finite source ObservableSource, mapped by the keys returned by a specified
keySelector function. |
<K,V> Single<Map<K,V>> |
Observable.toMap(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector)
Returns a Single that emits a single HashMap containing values corresponding to items emitted by the
finite source ObservableSource, mapped by the keys returned by a specified
keySelector function. |
<K,V> Single<Map<K,V>> |
Flowable.toMap(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector)
Returns a Single that emits a single HashMap containing values corresponding to items emitted by the
finite source Publisher, mapped by the keys returned by a specified
keySelector function. |
<K,V> Single<Map<K,V>> |
Flowable.toMap(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector)
Returns a Single that emits a single HashMap containing values corresponding to items emitted by the
finite source Publisher, mapped by the keys returned by a specified
keySelector function. |
<K,V> Single<Map<K,V>> |
Observable.toMap(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
Callable<? extends Map<K,V>> mapSupplier)
Returns a Single that emits a single Map, returned by a specified
mapFactory function, that
contains keys and values extracted from the items emitted by the finite source ObservableSource. |
<K,V> Single<Map<K,V>> |
Observable.toMap(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
Callable<? extends Map<K,V>> mapSupplier)
Returns a Single that emits a single Map, returned by a specified
mapFactory function, that
contains keys and values extracted from the items emitted by the finite source ObservableSource. |
<K,V> Single<Map<K,V>> |
Flowable.toMap(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
Callable<? extends Map<K,V>> mapSupplier)
Returns a Single that emits a single Map, returned by a specified
mapFactory function, that
contains keys and values extracted from the items emitted by the finite source Publisher. |
<K,V> Single<Map<K,V>> |
Flowable.toMap(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
Callable<? extends Map<K,V>> mapSupplier)
Returns a Single that emits a single Map, returned by a specified
mapFactory function, that
contains keys and values extracted from the items emitted by the finite source Publisher. |
<K> Single<Map<K,Collection<T>>> |
Observable.toMultimap(Function<? super T,? extends K> keySelector)
Returns a Single that emits a single HashMap that contains an ArrayList of items emitted by the
finite source ObservableSource keyed by a specified
keySelector function. |
<K> Single<Map<K,Collection<T>>> |
Flowable.toMultimap(Function<? super T,? extends K> keySelector)
Returns a Single that emits a single HashMap that contains an ArrayList of items emitted by the
finite source Publisher keyed by a specified
keySelector function. |
<K,V> Single<Map<K,Collection<V>>> |
Observable.toMultimap(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector)
Returns a Single that emits a single HashMap that contains an ArrayList of values extracted by a
specified
valueSelector function from items emitted by the finite source ObservableSource,
keyed by a specified keySelector function. |
<K,V> Single<Map<K,Collection<V>>> |
Observable.toMultimap(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector)
Returns a Single that emits a single HashMap that contains an ArrayList of values extracted by a
specified
valueSelector function from items emitted by the finite source ObservableSource,
keyed by a specified keySelector function. |
<K,V> Single<Map<K,Collection<V>>> |
Flowable.toMultimap(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector)
Returns a Single that emits a single HashMap that contains an ArrayList of values extracted by a
specified
valueSelector function from items emitted by the finite source Publisher, keyed by a
specified keySelector function. |
<K,V> Single<Map<K,Collection<V>>> |
Flowable.toMultimap(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector)
Returns a Single that emits a single HashMap that contains an ArrayList of values extracted by a
specified
valueSelector function from items emitted by the finite source Publisher, keyed by a
specified keySelector function. |
<K,V> Single<Map<K,Collection<V>>> |
Observable.toMultimap(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
Callable<? extends Map<K,Collection<V>>> mapSupplier,
Function<? super K,? extends Collection<? super V>> collectionFactory)
Returns a Single that emits a single Map, returned by a specified
mapFactory function, that
contains a custom collection of values, extracted by a specified valueSelector function from
items emitted by the source ObservableSource, and keyed by the keySelector function. |
<K,V> Single<Map<K,Collection<V>>> |
Observable.toMultimap(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
Callable<? extends Map<K,Collection<V>>> mapSupplier,
Function<? super K,? extends Collection<? super V>> collectionFactory)
Returns a Single that emits a single Map, returned by a specified
mapFactory function, that
contains a custom collection of values, extracted by a specified valueSelector function from
items emitted by the source ObservableSource, and keyed by the keySelector function. |
<K,V> Single<Map<K,Collection<V>>> |
Observable.toMultimap(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
Callable<? extends Map<K,Collection<V>>> mapSupplier,
Function<? super K,? extends Collection<? super V>> collectionFactory)
Returns a Single that emits a single Map, returned by a specified
mapFactory function, that
contains a custom collection of values, extracted by a specified valueSelector function from
items emitted by the source ObservableSource, and keyed by the keySelector function. |
<K,V> Single<Map<K,Collection<V>>> |
Flowable.toMultimap(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
Callable<? extends Map<K,Collection<V>>> mapSupplier,
Function<? super K,? extends Collection<? super V>> collectionFactory)
Returns a Single that emits a single Map, returned by a specified
mapFactory function, that
contains a custom collection of values, extracted by a specified valueSelector function from
items emitted by the finite source Publisher, and keyed by the keySelector function. |
<K,V> Single<Map<K,Collection<V>>> |
Flowable.toMultimap(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
Callable<? extends Map<K,Collection<V>>> mapSupplier,
Function<? super K,? extends Collection<? super V>> collectionFactory)
Returns a Single that emits a single Map, returned by a specified
mapFactory function, that
contains a custom collection of values, extracted by a specified valueSelector function from
items emitted by the finite source Publisher, and keyed by the keySelector function. |
<K,V> Single<Map<K,Collection<V>>> |
Flowable.toMultimap(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
Callable<? extends Map<K,Collection<V>>> mapSupplier,
Function<? super K,? extends Collection<? super V>> collectionFactory)
Returns a Single that emits a single Map, returned by a specified
mapFactory function, that
contains a custom collection of values, extracted by a specified valueSelector function from
items emitted by the finite source Publisher, and keyed by the keySelector function. |
<K,V> Single<Map<K,Collection<V>>> |
Observable.toMultimap(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
Callable<Map<K,Collection<V>>> mapSupplier)
Returns a Single that emits a single Map, returned by a specified
mapFactory function, that
contains an ArrayList of values, extracted by a specified valueSelector function from items
emitted by the finite source ObservableSource and keyed by the keySelector function. |
<K,V> Single<Map<K,Collection<V>>> |
Observable.toMultimap(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
Callable<Map<K,Collection<V>>> mapSupplier)
Returns a Single that emits a single Map, returned by a specified
mapFactory function, that
contains an ArrayList of values, extracted by a specified valueSelector function from items
emitted by the finite source ObservableSource and keyed by the keySelector function. |
<K,V> Single<Map<K,Collection<V>>> |
Flowable.toMultimap(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
Callable<Map<K,Collection<V>>> mapSupplier)
Returns a Single that emits a single Map, returned by a specified
mapFactory function, that
contains an ArrayList of values, extracted by a specified valueSelector function from items
emitted by the finite source Publisher and keyed by the keySelector function. |
<K,V> Single<Map<K,Collection<V>>> |
Flowable.toMultimap(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
Callable<Map<K,Collection<V>>> mapSupplier)
Returns a Single that emits a single Map, returned by a specified
mapFactory function, that
contains an ArrayList of values, extracted by a specified valueSelector function from items
emitted by the finite source Publisher and keyed by the keySelector function. |
static <T,D> Maybe<T> |
Maybe.using(Callable<? extends D> resourceSupplier,
Function<? super D,? extends MaybeSource<? extends T>> sourceSupplier,
Consumer<? super D> resourceDisposer)
Constructs a Maybe that creates a dependent resource object which is disposed of when the
upstream terminates or the downstream calls dispose().
|
static <T,D> Maybe<T> |
Maybe.using(Callable<? extends D> resourceSupplier,
Function<? super D,? extends MaybeSource<? extends T>> sourceSupplier,
Consumer<? super D> resourceDisposer,
boolean eager)
Constructs a Maybe that creates a dependent resource object which is disposed of just before
termination if you have set
disposeEagerly to true and a downstream dispose() does not occur
before termination. |
static <T,D> Observable<T> |
Observable.using(Callable<? extends D> resourceSupplier,
Function<? super D,? extends ObservableSource<? extends T>> sourceSupplier,
Consumer<? super D> disposer)
Constructs an ObservableSource that creates a dependent resource object which is disposed of when the downstream
calls dispose().
|
static <T,D> Observable<T> |
Observable.using(Callable<? extends D> resourceSupplier,
Function<? super D,? extends ObservableSource<? extends T>> sourceSupplier,
Consumer<? super D> disposer,
boolean eager)
Constructs an ObservableSource that creates a dependent resource object which is disposed of just before
termination if you have set
disposeEagerly to true and a dispose() call does not occur
before termination. |
static <T,D> Flowable<T> |
Flowable.using(Callable<? extends D> resourceSupplier,
Function<? super D,? extends org.reactivestreams.Publisher<? extends T>> sourceSupplier,
Consumer<? super D> resourceDisposer)
Constructs a Publisher that creates a dependent resource object which is disposed of on cancellation.
|
static <T,D> Flowable<T> |
Flowable.using(Callable<? extends D> resourceSupplier,
Function<? super D,? extends org.reactivestreams.Publisher<? extends T>> sourceSupplier,
Consumer<? super D> resourceDisposer,
boolean eager)
Constructs a Publisher that creates a dependent resource object which is disposed of just before
termination if you have set
disposeEagerly to true and cancellation does not occur
before termination. |
static <R> Completable |
Completable.using(Callable<R> resourceSupplier,
Function<? super R,? extends CompletableSource> completableFunction,
Consumer<? super R> disposer)
Returns a Completable instance which manages a resource along
with a custom Completable instance while the subscription is active.
|
static <R> Completable |
Completable.using(Callable<R> resourceSupplier,
Function<? super R,? extends CompletableSource> completableFunction,
Consumer<? super R> disposer,
boolean eager)
Returns a Completable instance which manages a resource along
with a custom Completable instance while the subscription is active and performs eager or lazy
resource disposition.
|
static <T,U> Single<T> |
Single.using(Callable<U> resourceSupplier,
Function<? super U,? extends SingleSource<? extends T>> singleFunction,
Consumer<? super U> disposer)
Allows using and disposing a resource while running a SingleSource instance generated from
that resource (similar to a try-with-resources).
|
static <T,U> Single<T> |
Single.using(Callable<U> resourceSupplier,
Function<? super U,? extends SingleSource<? extends T>> singleFunction,
Consumer<? super U> disposer,
boolean eager)
Allows using and disposing a resource while running a SingleSource instance generated from
that resource (similar to a try-with-resources).
|
<S extends Scheduler & Disposable> |
Scheduler.when(Function<Flowable<Flowable<Completable>>,Completable> combine)
Allows the use of operators for controlling the timing around when
actions scheduled on workers are actually done.
|
<U,V> Observable<Observable<T>> |
Observable.window(ObservableSource<U> openingIndicator,
Function<? super U,? extends ObservableSource<V>> closingIndicator)
Returns an Observable that emits windows of items it collects from the source ObservableSource.
|
<U,V> Observable<Observable<T>> |
Observable.window(ObservableSource<U> openingIndicator,
Function<? super U,? extends ObservableSource<V>> closingIndicator,
int bufferSize)
Returns an Observable that emits windows of items it collects from the source ObservableSource.
|
<U,V> Flowable<Flowable<T>> |
Flowable.window(org.reactivestreams.Publisher<U> openingIndicator,
Function<? super U,? extends org.reactivestreams.Publisher<V>> closingIndicator)
Returns a Flowable that emits windows of items it collects from the source Publisher.
|
<U,V> Flowable<Flowable<T>> |
Flowable.window(org.reactivestreams.Publisher<U> openingIndicator,
Function<? super U,? extends org.reactivestreams.Publisher<V>> closingIndicator,
int bufferSize)
Returns a Flowable that emits windows of items it collects from the source Publisher.
|
<R> Observable<R> |
Observable.withLatestFrom(Iterable<? extends ObservableSource<?>> others,
Function<? super Object[],R> combiner)
Combines the value emission from this ObservableSource with the latest emissions from the
other ObservableSources via a function to produce the output item.
|
<R> Flowable<R> |
Flowable.withLatestFrom(Iterable<? extends org.reactivestreams.Publisher<?>> others,
Function<? super Object[],R> combiner)
Combines the value emission from this Publisher with the latest emissions from the
other Publishers via a function to produce the output item.
|
<R> Observable<R> |
Observable.withLatestFrom(ObservableSource<?>[] others,
Function<? super Object[],R> combiner)
Combines the value emission from this ObservableSource with the latest emissions from the
other ObservableSources via a function to produce the output item.
|
<R> Flowable<R> |
Flowable.withLatestFrom(org.reactivestreams.Publisher<?>[] others,
Function<? super Object[],R> combiner)
Combines the value emission from this Publisher with the latest emissions from the
other Publishers via a function to produce the output item.
|
static <T,R> Maybe<R> |
Maybe.zip(Iterable<? extends MaybeSource<? extends T>> sources,
Function<? super Object[],? extends R> zipper)
Returns a Maybe that emits the results of a specified combiner function applied to combinations of
items emitted, in sequence, by an Iterable of other MaybeSources.
|
static <T,R> Observable<R> |
Observable.zip(Iterable<? extends ObservableSource<? extends T>> sources,
Function<? super Object[],? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
items emitted, in sequence, by an Iterable of other ObservableSources.
|
static <T,R> Flowable<R> |
Flowable.zip(Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources,
Function<? super Object[],? extends R> zipper)
Returns a Flowable that emits the results of a specified combiner function applied to combinations of
items emitted, in sequence, by an Iterable of other Publishers.
|
static <T,R> Single<R> |
Single.zip(Iterable<? extends SingleSource<? extends T>> sources,
Function<? super Object[],? extends R> zipper)
Waits until all SingleSource sources provided by the Iterable sequence signal a success
value and calls a zipper function with an array of these values to return a result
to be emitted to downstream.
|
static <T,R> Observable<R> |
Observable.zip(ObservableSource<? extends ObservableSource<? extends T>> sources,
Function<? super Object[],? extends R> zipper)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
n items emitted, in sequence, by the n ObservableSources emitted by a specified ObservableSource.
|
static <T,R> Flowable<R> |
Flowable.zip(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends T>> sources,
Function<? super Object[],? extends R> zipper)
Returns a Flowable that emits the results of a specified combiner function applied to combinations of
n items emitted, in sequence, by the n Publishers emitted by a specified Publisher.
|
static <T,R> Observable<R> |
Observable.zipArray(Function<? super Object[],? extends R> zipper,
boolean delayError,
int bufferSize,
ObservableSource<? extends T>... sources)
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 ObservableSources.
|
static <T,R> Flowable<R> |
Flowable.zipArray(Function<? super Object[],? extends R> zipper,
boolean delayError,
int bufferSize,
org.reactivestreams.Publisher<? extends T>... sources)
Returns a Flowable that emits the results of a specified combiner function applied to combinations of
items emitted, in sequence, by an array of other Publishers.
|
static <T,R> Maybe<R> |
Maybe.zipArray(Function<? super Object[],? extends R> zipper,
MaybeSource<? extends T>... sources)
Returns a Maybe that emits the results of a specified combiner function applied to combinations of
items emitted, in sequence, by an array of other MaybeSources.
|
static <T,R> Single<R> |
Single.zipArray(Function<? super Object[],? extends R> zipper,
SingleSource<? extends T>... sources)
Waits until all SingleSource sources provided via an array signal a success
value and calls a zipper function with an array of these values to return a result
to be emitted to downstream.
|
static <T,R> Observable<R> |
Observable.zipIterable(Iterable<? extends ObservableSource<? extends T>> sources,
Function<? super Object[],? extends R> zipper,
boolean delayError,
int bufferSize)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
items emitted, in sequence, by an Iterable of other ObservableSources.
|
static <T,R> Flowable<R> |
Flowable.zipIterable(Iterable<? extends org.reactivestreams.Publisher<? extends T>> sources,
Function<? super Object[],? extends R> zipper,
boolean delayError,
int bufferSize)
Returns a Flowable that emits the results of a specified combiner function applied to combinations of
items emitted, in sequence, by an Iterable of other Publishers.
|
Modifier and Type | Method and Description |
---|---|
static <T,U> Function<T,U> |
Functions.castFunction(Class<U> target)
Returns a function that cast the incoming values via a Class object.
|
static <T> Function<T,T> |
Functions.identity()
Returns an identity function that simply returns its argument.
|
static <T,U> Function<T,U> |
Functions.justFunction(U value)
Returns a Function that ignores its parameter and returns the given value.
|
static <T> Function<List<T>,List<T>> |
Functions.listSorter(Comparator<? super T> comparator) |
static <T> Function<T,Timed<T>> |
Functions.timestampWith(TimeUnit unit,
Scheduler scheduler) |
static <T1,T2,R> Function<Object[],R> |
Functions.toFunction(BiFunction<? super T1,? super T2,? extends R> f) |
static <T1,T2,T3,R> |
Functions.toFunction(Function3<T1,T2,T3,R> f) |
static <T1,T2,T3,T4,R> |
Functions.toFunction(Function4<T1,T2,T3,T4,R> f) |
static <T1,T2,T3,T4,T5,R> |
Functions.toFunction(Function5<T1,T2,T3,T4,T5,R> f) |
static <T1,T2,T3,T4,T5,T6,R> |
Functions.toFunction(Function6<T1,T2,T3,T4,T5,T6,R> f) |
static <T1,T2,T3,T4,T5,T6,T7,R> |
Functions.toFunction(Function7<T1,T2,T3,T4,T5,T6,T7,R> f) |
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Functions.toFunction(Function8<T1,T2,T3,T4,T5,T6,T7,T8,R> f) |
static <T1,T2,T3,T4,T5,T6,T7,T8,T9,R> |
Functions.toFunction(Function9<T1,T2,T3,T4,T5,T6,T7,T8,T9,R> f) |
Modifier and Type | Method and Description |
---|---|
static <T,K> BiConsumer<Map<K,T>,T> |
Functions.toMapKeySelector(Function<? super T,? extends K> keySelector) |
static <T,K,V> BiConsumer<Map<K,V>,T> |
Functions.toMapKeyValueSelector(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector) |
static <T,K,V> BiConsumer<Map<K,V>,T> |
Functions.toMapKeyValueSelector(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector) |
static <T,K,V> BiConsumer<Map<K,Collection<V>>,T> |
Functions.toMultimapKeyValueSelector(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
Function<? super K,? extends Collection<? super V>> collectionFactory) |
static <T,K,V> BiConsumer<Map<K,Collection<V>>,T> |
Functions.toMultimapKeyValueSelector(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
Function<? super K,? extends Collection<? super V>> collectionFactory) |
static <T,K,V> BiConsumer<Map<K,Collection<V>>,T> |
Functions.toMultimapKeyValueSelector(Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
Function<? super K,? extends Collection<? super V>> collectionFactory) |
Constructor and Description |
---|
CompletableResumeNext(CompletableSource source,
Function<? super Throwable,? extends CompletableSource> errorMapper) |
CompletableUsing(Callable<R> resourceSupplier,
Function<? super R,? extends CompletableSource> completableFunction,
Consumer<? super R> disposer,
boolean eager) |
Modifier and Type | Method and Description |
---|---|
static <T,U> Function<T,org.reactivestreams.Publisher<U>> |
FlowableInternalHelper.flatMapIntoIterable(Function<? super T,? extends Iterable<? extends U>> mapper) |
static <T,U,R> Function<T,org.reactivestreams.Publisher<R>> |
FlowableInternalHelper.flatMapWithCombiner(Function<? super T,? extends org.reactivestreams.Publisher<? extends U>> mapper,
BiFunction<? super T,? super U,? extends R> combiner) |
static <T,U> Function<T,org.reactivestreams.Publisher<T>> |
FlowableInternalHelper.itemDelay(Function<? super T,? extends org.reactivestreams.Publisher<U>> itemDelay) |
static <T,R> Function<Flowable<T>,org.reactivestreams.Publisher<R>> |
FlowableInternalHelper.replayFunction(Function<? super Flowable<T>,? extends org.reactivestreams.Publisher<R>> selector,
Scheduler scheduler) |
static <T,R> Function<List<org.reactivestreams.Publisher<? extends T>>,org.reactivestreams.Publisher<? extends R>> |
FlowableInternalHelper.zipIterable(Function<? super Object[],? extends R> zipper) |
Modifier and Type | Method and Description |
---|---|
static <T,U> Function<T,org.reactivestreams.Publisher<U>> |
FlowableInternalHelper.flatMapIntoIterable(Function<? super T,? extends Iterable<? extends U>> mapper) |
static <T,U,R> Function<T,org.reactivestreams.Publisher<R>> |
FlowableInternalHelper.flatMapWithCombiner(Function<? super T,? extends org.reactivestreams.Publisher<? extends U>> mapper,
BiFunction<? super T,? super U,? extends R> combiner) |
static <T,U> Function<T,org.reactivestreams.Publisher<T>> |
FlowableInternalHelper.itemDelay(Function<? super T,? extends org.reactivestreams.Publisher<U>> itemDelay) |
static <U,R> Flowable<R> |
FlowableReplay.multicastSelector(Callable<? extends ConnectableFlowable<U>> connectableFactory,
Function<? super Flowable<U>,? extends org.reactivestreams.Publisher<R>> selector)
Given a connectable observable factory, it multicasts over the generated
ConnectableObservable via a selector function.
|
static <T,R> Function<Flowable<T>,org.reactivestreams.Publisher<R>> |
FlowableInternalHelper.replayFunction(Function<? super Flowable<T>,? extends org.reactivestreams.Publisher<R>> selector,
Scheduler scheduler) |
static <T,U> Flowable<U> |
FlowableScalarXMap.scalarXMap(T value,
Function<? super T,? extends org.reactivestreams.Publisher<? extends U>> mapper)
Maps a scalar value into a Publisher and emits its values.
|
static <T,R> org.reactivestreams.Subscriber<T> |
FlowableConcatMap.subscribe(org.reactivestreams.Subscriber<? super R> s,
Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
int prefetch,
ErrorMode errorMode) |
static <T,U> FlowableSubscriber<T> |
FlowableFlatMap.subscribe(org.reactivestreams.Subscriber<? super U> s,
Function<? super T,? extends org.reactivestreams.Publisher<? extends U>> mapper,
boolean delayErrors,
int maxConcurrency,
int bufferSize) |
static <T,R> boolean |
FlowableScalarXMap.tryScalarXMapSubscribe(org.reactivestreams.Publisher<T> source,
org.reactivestreams.Subscriber<? super R> subscriber,
Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper)
Tries to subscribe to a possibly Callable source's mapped Publisher.
|
static <T,R> Function<List<org.reactivestreams.Publisher<? extends T>>,org.reactivestreams.Publisher<? extends R>> |
FlowableInternalHelper.zipIterable(Function<? super Object[],? extends R> zipper) |
Constructor and Description |
---|
FlowableBufferBoundary(Flowable<T> source,
org.reactivestreams.Publisher<? extends Open> bufferOpen,
Function<? super Open,? extends org.reactivestreams.Publisher<? extends Close>> bufferClose,
Callable<U> bufferSupplier) |
FlowableCombineLatest(Iterable<? extends org.reactivestreams.Publisher<? extends T>> iterable,
Function<? super Object[],? extends R> combiner,
int bufferSize,
boolean delayErrors) |
FlowableCombineLatest(org.reactivestreams.Publisher<? extends T>[] array,
Function<? super Object[],? extends R> combiner,
int bufferSize,
boolean delayErrors) |
FlowableConcatMap(Flowable<T> source,
Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
int prefetch,
ErrorMode errorMode) |
FlowableConcatMapEager(Flowable<T> source,
Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
int maxConcurrency,
int prefetch,
ErrorMode errorMode) |
FlowableConcatMapEagerPublisher(org.reactivestreams.Publisher<T> source,
Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
int maxConcurrency,
int prefetch,
ErrorMode errorMode) |
FlowableConcatMapPublisher(org.reactivestreams.Publisher<T> source,
Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
int prefetch,
ErrorMode errorMode) |
FlowableDebounce(Flowable<T> source,
Function<? super T,? extends org.reactivestreams.Publisher<U>> debounceSelector) |
FlowableDematerialize(Flowable<T> source,
Function<? super T,? extends Notification<R>> selector) |
FlowableDistinct(Flowable<T> source,
Function<? super T,K> keySelector,
Callable<? extends Collection<? super K>> collectionSupplier) |
FlowableDistinctUntilChanged(Flowable<T> source,
Function<? super T,K> keySelector,
BiPredicate<? super K,? super K> comparer) |
FlowableFlatMap(Flowable<T> source,
Function<? super T,? extends org.reactivestreams.Publisher<? extends U>> mapper,
boolean delayErrors,
int maxConcurrency,
int bufferSize) |
FlowableFlatMapCompletable(Flowable<T> source,
Function<? super T,? extends CompletableSource> mapper,
boolean delayErrors,
int maxConcurrency) |
FlowableFlatMapCompletableCompletable(Flowable<T> source,
Function<? super T,? extends CompletableSource> mapper,
boolean delayErrors,
int maxConcurrency) |
FlowableFlatMapMaybe(Flowable<T> source,
Function<? super T,? extends MaybeSource<? extends R>> mapper,
boolean delayError,
int maxConcurrency) |
FlowableFlatMapPublisher(org.reactivestreams.Publisher<T> source,
Function<? super T,? extends org.reactivestreams.Publisher<? extends U>> mapper,
boolean delayErrors,
int maxConcurrency,
int bufferSize) |
FlowableFlatMapSingle(Flowable<T> source,
Function<? super T,? extends SingleSource<? extends R>> mapper,
boolean delayError,
int maxConcurrency) |
FlowableFlattenIterable(Flowable<T> source,
Function<? super T,? extends Iterable<? extends R>> mapper,
int prefetch) |
FlowableGroupBy(Flowable<T> source,
Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
int bufferSize,
boolean delayError,
Function<? super Consumer<Object>,? extends Map<K,Object>> mapFactory) |
FlowableGroupBy(Flowable<T> source,
Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
int bufferSize,
boolean delayError,
Function<? super Consumer<Object>,? extends Map<K,Object>> mapFactory) |
FlowableGroupBy(Flowable<T> source,
Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
int bufferSize,
boolean delayError,
Function<? super Consumer<Object>,? extends Map<K,Object>> mapFactory) |
FlowableGroupJoin(Flowable<TLeft> source,
org.reactivestreams.Publisher<? extends TRight> other,
Function<? super TLeft,? extends org.reactivestreams.Publisher<TLeftEnd>> leftEnd,
Function<? super TRight,? extends org.reactivestreams.Publisher<TRightEnd>> rightEnd,
BiFunction<? super TLeft,? super Flowable<TRight>,? extends R> resultSelector) |
FlowableGroupJoin(Flowable<TLeft> source,
org.reactivestreams.Publisher<? extends TRight> other,
Function<? super TLeft,? extends org.reactivestreams.Publisher<TLeftEnd>> leftEnd,
Function<? super TRight,? extends org.reactivestreams.Publisher<TRightEnd>> rightEnd,
BiFunction<? super TLeft,? super Flowable<TRight>,? extends R> resultSelector) |
FlowableJoin(Flowable<TLeft> source,
org.reactivestreams.Publisher<? extends TRight> other,
Function<? super TLeft,? extends org.reactivestreams.Publisher<TLeftEnd>> leftEnd,
Function<? super TRight,? extends org.reactivestreams.Publisher<TRightEnd>> rightEnd,
BiFunction<? super TLeft,? super TRight,? extends R> resultSelector) |
FlowableJoin(Flowable<TLeft> source,
org.reactivestreams.Publisher<? extends TRight> other,
Function<? super TLeft,? extends org.reactivestreams.Publisher<TLeftEnd>> leftEnd,
Function<? super TRight,? extends org.reactivestreams.Publisher<TRightEnd>> rightEnd,
BiFunction<? super TLeft,? super TRight,? extends R> resultSelector) |
FlowableMap(Flowable<T> source,
Function<? super T,? extends U> mapper) |
FlowableMapNotification(Flowable<T> source,
Function<? super T,? extends R> onNextMapper,
Function<? super Throwable,? extends R> onErrorMapper,
Callable<? extends R> onCompleteSupplier) |
FlowableMapNotification(Flowable<T> source,
Function<? super T,? extends R> onNextMapper,
Function<? super Throwable,? extends R> onErrorMapper,
Callable<? extends R> onCompleteSupplier) |
FlowableMapPublisher(org.reactivestreams.Publisher<T> source,
Function<? super T,? extends U> mapper) |
FlowableOnErrorNext(Flowable<T> source,
Function<? super Throwable,? extends org.reactivestreams.Publisher<? extends T>> nextSupplier,
boolean allowFatal) |
FlowableOnErrorReturn(Flowable<T> source,
Function<? super Throwable,? extends T> valueSupplier) |
FlowablePublishMulticast(Flowable<T> source,
Function<? super Flowable<T>,? extends org.reactivestreams.Publisher<? extends R>> selector,
int prefetch,
boolean delayError) |
FlowableRepeatWhen(Flowable<T> source,
Function<? super Flowable<Object>,? extends org.reactivestreams.Publisher<?>> handler) |
FlowableRetryWhen(Flowable<T> source,
Function<? super Flowable<Throwable>,? extends org.reactivestreams.Publisher<?>> handler) |
FlowableSwitchMap(Flowable<T> source,
Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
int bufferSize,
boolean delayErrors) |
FlowableTimeout(Flowable<T> source,
org.reactivestreams.Publisher<U> firstTimeoutIndicator,
Function<? super T,? extends org.reactivestreams.Publisher<V>> itemTimeoutIndicator,
org.reactivestreams.Publisher<? extends T> other) |
FlowableUsing(Callable<? extends D> resourceSupplier,
Function<? super D,? extends org.reactivestreams.Publisher<? extends T>> sourceSupplier,
Consumer<? super D> disposer,
boolean eager) |
FlowableWindowBoundarySelector(Flowable<T> source,
org.reactivestreams.Publisher<B> open,
Function<? super B,? extends org.reactivestreams.Publisher<V>> close,
int bufferSize) |
FlowableWithLatestFromMany(Flowable<T> source,
Iterable<? extends org.reactivestreams.Publisher<?>> otherIterable,
Function<? super Object[],R> combiner) |
FlowableWithLatestFromMany(Flowable<T> source,
org.reactivestreams.Publisher<?>[] otherArray,
Function<? super Object[],R> combiner) |
FlowableZip(org.reactivestreams.Publisher<? extends T>[] sources,
Iterable<? extends org.reactivestreams.Publisher<? extends T>> sourcesIterable,
Function<? super Object[],? extends R> zipper,
int bufferSize,
boolean delayError) |
GroupBySubscriber(org.reactivestreams.Subscriber<? super GroupedFlowable<K,V>> actual,
Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
int bufferSize,
boolean delayError,
Map<Object,io.reactivex.internal.operators.flowable.FlowableGroupBy.GroupedUnicast<K,V>> groups,
Queue<io.reactivex.internal.operators.flowable.FlowableGroupBy.GroupedUnicast<K,V>> evictedGroups) |
GroupBySubscriber(org.reactivestreams.Subscriber<? super GroupedFlowable<K,V>> actual,
Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
int bufferSize,
boolean delayError,
Map<Object,io.reactivex.internal.operators.flowable.FlowableGroupBy.GroupedUnicast<K,V>> groups,
Queue<io.reactivex.internal.operators.flowable.FlowableGroupBy.GroupedUnicast<K,V>> evictedGroups) |
Modifier and Type | Class and Description |
---|---|
class |
MaybeToPublisher
Helper function to merge/concat values of each MaybeSource provided by a Publisher.
|
Modifier and Type | Method and Description |
---|---|
static <T> Function<MaybeSource<T>,org.reactivestreams.Publisher<T>> |
MaybeToPublisher.instance() |
Constructor and Description |
---|
MaybeFlatMapBiSelector(MaybeSource<T> source,
Function<? super T,? extends MaybeSource<? extends U>> mapper,
BiFunction<? super T,? super U,? extends R> resultSelector) |
MaybeFlatMapCompletable(MaybeSource<T> source,
Function<? super T,? extends CompletableSource> mapper) |
MaybeFlatMapIterableFlowable(MaybeSource<T> source,
Function<? super T,? extends Iterable<? extends R>> mapper) |
MaybeFlatMapIterableObservable(MaybeSource<T> source,
Function<? super T,? extends Iterable<? extends R>> mapper) |
MaybeFlatMapNotification(MaybeSource<T> source,
Function<? super T,? extends MaybeSource<? extends R>> onSuccessMapper,
Function<? super Throwable,? extends MaybeSource<? extends R>> onErrorMapper,
Callable<? extends MaybeSource<? extends R>> onCompleteSupplier) |
MaybeFlatMapNotification(MaybeSource<T> source,
Function<? super T,? extends MaybeSource<? extends R>> onSuccessMapper,
Function<? super Throwable,? extends MaybeSource<? extends R>> onErrorMapper,
Callable<? extends MaybeSource<? extends R>> onCompleteSupplier) |
MaybeFlatMapSingle(MaybeSource<T> source,
Function<? super T,? extends SingleSource<? extends R>> mapper) |
MaybeFlatMapSingleElement(MaybeSource<T> source,
Function<? super T,? extends SingleSource<? extends R>> mapper) |
MaybeFlatten(MaybeSource<T> source,
Function<? super T,? extends MaybeSource<? extends R>> mapper) |
MaybeMap(MaybeSource<T> source,
Function<? super T,? extends R> mapper) |
MaybeOnErrorNext(MaybeSource<T> source,
Function<? super Throwable,? extends MaybeSource<? extends T>> resumeFunction,
boolean allowFatal) |
MaybeOnErrorReturn(MaybeSource<T> source,
Function<? super Throwable,? extends T> valueSupplier) |
MaybeUsing(Callable<? extends D> resourceSupplier,
Function<? super D,? extends MaybeSource<? extends T>> sourceSupplier,
Consumer<? super D> resourceDisposer,
boolean eager) |
MaybeZipArray(MaybeSource<? extends T>[] sources,
Function<? super Object[],? extends R> zipper) |
MaybeZipIterable(Iterable<? extends MaybeSource<? extends T>> sources,
Function<? super Object[],? extends R> zipper) |
Constructor and Description |
---|
FlowableConcatMapCompletable(Flowable<T> source,
Function<? super T,? extends CompletableSource> mapper,
ErrorMode errorMode,
int prefetch) |
FlowableConcatMapMaybe(Flowable<T> source,
Function<? super T,? extends MaybeSource<? extends R>> mapper,
ErrorMode errorMode,
int prefetch) |
FlowableConcatMapSingle(Flowable<T> source,
Function<? super T,? extends SingleSource<? extends R>> mapper,
ErrorMode errorMode,
int prefetch) |
FlowableSwitchMapCompletable(Flowable<T> source,
Function<? super T,? extends CompletableSource> mapper,
boolean delayErrors) |
FlowableSwitchMapMaybe(Flowable<T> source,
Function<? super T,? extends MaybeSource<? extends R>> mapper,
boolean delayErrors) |
FlowableSwitchMapSingle(Flowable<T> source,
Function<? super T,? extends SingleSource<? extends R>> mapper,
boolean delayErrors) |
MaybeFlatMapObservable(MaybeSource<T> source,
Function<? super T,? extends ObservableSource<? extends R>> mapper) |
MaybeFlatMapPublisher(MaybeSource<T> source,
Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper) |
ObservableConcatMapCompletable(Observable<T> source,
Function<? super T,? extends CompletableSource> mapper,
ErrorMode errorMode,
int prefetch) |
ObservableConcatMapMaybe(Observable<T> source,
Function<? super T,? extends MaybeSource<? extends R>> mapper,
ErrorMode errorMode,
int prefetch) |
ObservableConcatMapSingle(Observable<T> source,
Function<? super T,? extends SingleSource<? extends R>> mapper,
ErrorMode errorMode,
int prefetch) |
ObservableSwitchMapCompletable(Observable<T> source,
Function<? super T,? extends CompletableSource> mapper,
boolean delayErrors) |
ObservableSwitchMapMaybe(Observable<T> source,
Function<? super T,? extends MaybeSource<? extends R>> mapper,
boolean delayErrors) |
ObservableSwitchMapSingle(Observable<T> source,
Function<? super T,? extends SingleSource<? extends R>> mapper,
boolean delayErrors) |
SingleFlatMapObservable(SingleSource<T> source,
Function<? super T,? extends ObservableSource<? extends R>> mapper) |
Modifier and Type | Method and Description |
---|---|
static <T,U> Function<T,ObservableSource<U>> |
ObservableInternalHelper.flatMapIntoIterable(Function<? super T,? extends Iterable<? extends U>> mapper) |
static <T,U,R> Function<T,ObservableSource<R>> |
ObservableInternalHelper.flatMapWithCombiner(Function<? super T,? extends ObservableSource<? extends U>> mapper,
BiFunction<? super T,? super U,? extends R> combiner) |
static <T,U> Function<T,ObservableSource<T>> |
ObservableInternalHelper.itemDelay(Function<? super T,? extends ObservableSource<U>> itemDelay) |
static <T,R> Function<Observable<T>,ObservableSource<R>> |
ObservableInternalHelper.replayFunction(Function<? super Observable<T>,? extends ObservableSource<R>> selector,
Scheduler scheduler) |
static <T,R> Function<List<ObservableSource<? extends T>>,ObservableSource<? extends R>> |
ObservableInternalHelper.zipIterable(Function<? super Object[],? extends R> zipper) |
Modifier and Type | Method and Description |
---|---|
static <T,U> Function<T,ObservableSource<U>> |
ObservableInternalHelper.flatMapIntoIterable(Function<? super T,? extends Iterable<? extends U>> mapper) |
static <T,U,R> Function<T,ObservableSource<R>> |
ObservableInternalHelper.flatMapWithCombiner(Function<? super T,? extends ObservableSource<? extends U>> mapper,
BiFunction<? super T,? super U,? extends R> combiner) |
static <T,U> Function<T,ObservableSource<T>> |
ObservableInternalHelper.itemDelay(Function<? super T,? extends ObservableSource<U>> itemDelay) |
static <U,R> Observable<R> |
ObservableReplay.multicastSelector(Callable<? extends ConnectableObservable<U>> connectableFactory,
Function<? super Observable<U>,? extends ObservableSource<R>> selector)
Given a connectable observable factory, it multicasts over the generated
ConnectableObservable via a selector function.
|
static <T,R> Function<Observable<T>,ObservableSource<R>> |
ObservableInternalHelper.replayFunction(Function<? super Observable<T>,? extends ObservableSource<R>> selector,
Scheduler scheduler) |
static <T,U> Observable<U> |
ObservableScalarXMap.scalarXMap(T value,
Function<? super T,? extends ObservableSource<? extends U>> mapper)
Maps a scalar value into an Observable and emits its values.
|
static <T,R> boolean |
ObservableScalarXMap.tryScalarXMapSubscribe(ObservableSource<T> source,
Observer<? super R> observer,
Function<? super T,? extends ObservableSource<? extends R>> mapper)
Tries to subscribe to a possibly Callable source's mapped ObservableSource.
|
static <T,R> Function<List<ObservableSource<? extends T>>,ObservableSource<? extends R>> |
ObservableInternalHelper.zipIterable(Function<? super Object[],? extends R> zipper) |
Constructor and Description |
---|
GroupByObserver(Observer<? super GroupedObservable<K,V>> actual,
Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
int bufferSize,
boolean delayError) |
GroupByObserver(Observer<? super GroupedObservable<K,V>> actual,
Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
int bufferSize,
boolean delayError) |
ObservableBufferBoundary(ObservableSource<T> source,
ObservableSource<? extends Open> bufferOpen,
Function<? super Open,? extends ObservableSource<? extends Close>> bufferClose,
Callable<U> bufferSupplier) |
ObservableCombineLatest(ObservableSource<? extends T>[] sources,
Iterable<? extends ObservableSource<? extends T>> sourcesIterable,
Function<? super Object[],? extends R> combiner,
int bufferSize,
boolean delayError) |
ObservableConcatMap(ObservableSource<T> source,
Function<? super T,? extends ObservableSource<? extends U>> mapper,
int bufferSize,
ErrorMode delayErrors) |
ObservableConcatMapEager(ObservableSource<T> source,
Function<? super T,? extends ObservableSource<? extends R>> mapper,
ErrorMode errorMode,
int maxConcurrency,
int prefetch) |
ObservableDebounce(ObservableSource<T> source,
Function<? super T,? extends ObservableSource<U>> debounceSelector) |
ObservableDematerialize(ObservableSource<T> source,
Function<? super T,? extends Notification<R>> selector) |
ObservableDistinct(ObservableSource<T> source,
Function<? super T,K> keySelector,
Callable<? extends Collection<? super K>> collectionSupplier) |
ObservableDistinctUntilChanged(ObservableSource<T> source,
Function<? super T,K> keySelector,
BiPredicate<? super K,? super K> comparer) |
ObservableFlatMap(ObservableSource<T> source,
Function<? super T,? extends ObservableSource<? extends U>> mapper,
boolean delayErrors,
int maxConcurrency,
int bufferSize) |
ObservableFlatMapCompletable(ObservableSource<T> source,
Function<? super T,? extends CompletableSource> mapper,
boolean delayErrors) |
ObservableFlatMapCompletableCompletable(ObservableSource<T> source,
Function<? super T,? extends CompletableSource> mapper,
boolean delayErrors) |
ObservableFlatMapMaybe(ObservableSource<T> source,
Function<? super T,? extends MaybeSource<? extends R>> mapper,
boolean delayError) |
ObservableFlatMapSingle(ObservableSource<T> source,
Function<? super T,? extends SingleSource<? extends R>> mapper,
boolean delayError) |
ObservableFlattenIterable(ObservableSource<T> source,
Function<? super T,? extends Iterable<? extends R>> mapper) |
ObservableGroupBy(ObservableSource<T> source,
Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
int bufferSize,
boolean delayError) |
ObservableGroupBy(ObservableSource<T> source,
Function<? super T,? extends K> keySelector,
Function<? super T,? extends V> valueSelector,
int bufferSize,
boolean delayError) |
ObservableGroupJoin(ObservableSource<TLeft> source,
ObservableSource<? extends TRight> other,
Function<? super TLeft,? extends ObservableSource<TLeftEnd>> leftEnd,
Function<? super TRight,? extends ObservableSource<TRightEnd>> rightEnd,
BiFunction<? super TLeft,? super Observable<TRight>,? extends R> resultSelector) |
ObservableGroupJoin(ObservableSource<TLeft> source,
ObservableSource<? extends TRight> other,
Function<? super TLeft,? extends ObservableSource<TLeftEnd>> leftEnd,
Function<? super TRight,? extends ObservableSource<TRightEnd>> rightEnd,
BiFunction<? super TLeft,? super Observable<TRight>,? extends R> resultSelector) |
ObservableJoin(ObservableSource<TLeft> source,
ObservableSource<? extends TRight> other,
Function<? super TLeft,? extends ObservableSource<TLeftEnd>> leftEnd,
Function<? super TRight,? extends ObservableSource<TRightEnd>> rightEnd,
BiFunction<? super TLeft,? super TRight,? extends R> resultSelector) |
ObservableJoin(ObservableSource<TLeft> source,
ObservableSource<? extends TRight> other,
Function<? super TLeft,? extends ObservableSource<TLeftEnd>> leftEnd,
Function<? super TRight,? extends ObservableSource<TRightEnd>> rightEnd,
BiFunction<? super TLeft,? super TRight,? extends R> resultSelector) |
ObservableMap(ObservableSource<T> source,
Function<? super T,? extends U> function) |
ObservableMapNotification(ObservableSource<T> source,
Function<? super T,? extends ObservableSource<? extends R>> onNextMapper,
Function<? super Throwable,? extends ObservableSource<? extends R>> onErrorMapper,
Callable<? extends ObservableSource<? extends R>> onCompleteSupplier) |
ObservableMapNotification(ObservableSource<T> source,
Function<? super T,? extends ObservableSource<? extends R>> onNextMapper,
Function<? super Throwable,? extends ObservableSource<? extends R>> onErrorMapper,
Callable<? extends ObservableSource<? extends R>> onCompleteSupplier) |
ObservableOnErrorNext(ObservableSource<T> source,
Function<? super Throwable,? extends ObservableSource<? extends T>> nextSupplier,
boolean allowFatal) |
ObservableOnErrorReturn(ObservableSource<T> source,
Function<? super Throwable,? extends T> valueSupplier) |
ObservablePublishSelector(ObservableSource<T> source,
Function<? super Observable<T>,? extends ObservableSource<R>> selector) |
ObservableRepeatWhen(ObservableSource<T> source,
Function<? super Observable<Object>,? extends ObservableSource<?>> handler) |
ObservableRetryWhen(ObservableSource<T> source,
Function<? super Observable<Throwable>,? extends ObservableSource<?>> handler) |
ObservableSwitchMap(ObservableSource<T> source,
Function<? super T,? extends ObservableSource<? extends R>> mapper,
int bufferSize,
boolean delayErrors) |
ObservableTimeout(Observable<T> source,
ObservableSource<U> firstTimeoutIndicator,
Function<? super T,? extends ObservableSource<V>> itemTimeoutIndicator,
ObservableSource<? extends T> other) |
ObservableUsing(Callable<? extends D> resourceSupplier,
Function<? super D,? extends ObservableSource<? extends T>> sourceSupplier,
Consumer<? super D> disposer,
boolean eager) |
ObservableWindowBoundarySelector(ObservableSource<T> source,
ObservableSource<B> open,
Function<? super B,? extends ObservableSource<V>> close,
int bufferSize) |
ObservableWithLatestFromMany(ObservableSource<T> source,
Iterable<? extends ObservableSource<?>> otherIterable,
Function<? super Object[],R> combiner) |
ObservableWithLatestFromMany(ObservableSource<T> source,
ObservableSource<?>[] otherArray,
Function<? super Object[],R> combiner) |
ObservableZip(ObservableSource<? extends T>[] sources,
Iterable<? extends ObservableSource<? extends T>> sourcesIterable,
Function<? super Object[],? extends R> zipper,
int bufferSize,
boolean delayError) |
Constructor and Description |
---|
ParallelConcatMap(ParallelFlowable<T> source,
Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
int prefetch,
ErrorMode errorMode) |
ParallelFlatMap(ParallelFlowable<T> source,
Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
boolean delayError,
int maxConcurrency,
int prefetch) |
ParallelMap(ParallelFlowable<T> source,
Function<? super T,? extends R> mapper) |
ParallelMapTry(ParallelFlowable<T> source,
Function<? super T,? extends R> mapper,
BiFunction<? super Long,? super Throwable,ParallelFailureHandling> errorHandler) |
Modifier and Type | Method and Description |
---|---|
static <T> Function<SingleSource<? extends T>,org.reactivestreams.Publisher<? extends T>> |
SingleInternalHelper.toFlowable() |
static <T> Function<SingleSource<? extends T>,Observable<? extends T>> |
SingleInternalHelper.toObservable() |
Constructor and Description |
---|
SingleDematerialize(Single<T> source,
Function<? super T,Notification<R>> selector) |
SingleFlatMap(SingleSource<? extends T> source,
Function<? super T,? extends SingleSource<? extends R>> mapper) |
SingleFlatMapCompletable(SingleSource<T> source,
Function<? super T,? extends CompletableSource> mapper) |
SingleFlatMapIterableFlowable(SingleSource<T> source,
Function<? super T,? extends Iterable<? extends R>> mapper) |
SingleFlatMapIterableObservable(SingleSource<T> source,
Function<? super T,? extends Iterable<? extends R>> mapper) |
SingleFlatMapMaybe(SingleSource<? extends T> source,
Function<? super T,? extends MaybeSource<? extends R>> mapper) |
SingleFlatMapPublisher(SingleSource<T> source,
Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper) |
SingleMap(SingleSource<? extends T> source,
Function<? super T,? extends R> mapper) |
SingleOnErrorReturn(SingleSource<? extends T> source,
Function<? super Throwable,? extends T> valueSupplier,
T value) |
SingleResumeNext(SingleSource<? extends T> source,
Function<? super Throwable,? extends SingleSource<? extends T>> nextFunction) |
SingleUsing(Callable<U> resourceSupplier,
Function<? super U,? extends SingleSource<? extends T>> singleFunction,
Consumer<? super U> disposer,
boolean eager) |
SingleZipArray(SingleSource<? extends T>[] sources,
Function<? super Object[],? extends R> zipper) |
SingleZipIterable(Iterable<? extends SingleSource<? extends T>> sources,
Function<? super Object[],? extends R> zipper) |
Constructor and Description |
---|
SchedulerWhen(Function<Flowable<Flowable<Completable>>,Completable> combine,
Scheduler actualScheduler) |
Modifier and Type | Class and Description |
---|---|
class |
ArrayListSupplier |
class |
SorterFunction<T> |
Modifier and Type | Method and Description |
---|---|
static <T,O> Function<O,List<T>> |
ArrayListSupplier.asFunction() |
Modifier and Type | Method and Description |
---|---|
<R> ParallelFlowable<R> |
ParallelFlowable.concatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper)
Generates and concatenates Publishers on each 'rail', signalling errors immediately
and generating 2 publishers upfront.
|
<R> ParallelFlowable<R> |
ParallelFlowable.concatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
int prefetch)
Generates and concatenates Publishers on each 'rail', signalling errors immediately
and using the given prefetch amount for generating Publishers upfront.
|
<R> ParallelFlowable<R> |
ParallelFlowable.concatMapDelayError(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
boolean tillTheEnd)
Generates and concatenates Publishers on each 'rail', optionally delaying errors
and generating 2 publishers upfront.
|
<R> ParallelFlowable<R> |
ParallelFlowable.concatMapDelayError(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
int prefetch,
boolean tillTheEnd)
Generates and concatenates Publishers on each 'rail', optionally delaying errors
and using the given prefetch amount for generating Publishers upfront.
|
<R> ParallelFlowable<R> |
ParallelFlowable.flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper)
Generates and flattens Publishers on each 'rail'.
|
<R> ParallelFlowable<R> |
ParallelFlowable.flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
boolean delayError)
Generates and flattens Publishers on each 'rail', optionally delaying errors.
|
<R> ParallelFlowable<R> |
ParallelFlowable.flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
boolean delayError,
int maxConcurrency)
Generates and flattens Publishers on each 'rail', optionally delaying errors
and having a total number of simultaneous subscriptions to the inner Publishers.
|
<R> ParallelFlowable<R> |
ParallelFlowable.flatMap(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
boolean delayError,
int maxConcurrency,
int prefetch)
Generates and flattens Publishers on each 'rail', optionally delaying errors,
having a total number of simultaneous subscriptions to the inner Publishers
and using the given prefetch amount for the inner Publishers.
|
<R> ParallelFlowable<R> |
ParallelFlowable.map(Function<? super T,? extends R> mapper)
Maps the source values on each 'rail' to another value.
|
<R> ParallelFlowable<R> |
ParallelFlowable.map(Function<? super T,? extends R> mapper,
BiFunction<? super Long,? super Throwable,ParallelFailureHandling> errorHandler)
Maps the source values on each 'rail' to another value and
handles errors based on the returned value by the handler function.
|
<R> ParallelFlowable<R> |
ParallelFlowable.map(Function<? super T,? extends R> mapper,
ParallelFailureHandling errorHandler)
Maps the source values on each 'rail' to another value and
handles errors based on the given
ParallelFailureHandling enumeration value. |
<U> U |
ParallelFlowable.to(Function<? super ParallelFlowable<T>,U> converter)
Perform a fluent transformation to a value via a converter function which
receives this ParallelFlowable.
|
Modifier and Type | Method and Description |
---|---|
static Function<? super Scheduler,? extends Scheduler> |
RxJavaPlugins.getComputationSchedulerHandler()
Returns the current hook function.
|
static Function<? super Callable<Scheduler>,? extends Scheduler> |
RxJavaPlugins.getInitComputationSchedulerHandler()
Returns the current hook function.
|
static Function<? super Callable<Scheduler>,? extends Scheduler> |
RxJavaPlugins.getInitIoSchedulerHandler()
Returns the current hook function.
|
static Function<? super Callable<Scheduler>,? extends Scheduler> |
RxJavaPlugins.getInitNewThreadSchedulerHandler()
Returns the current hook function.
|
static Function<? super Callable<Scheduler>,? extends Scheduler> |
RxJavaPlugins.getInitSingleSchedulerHandler()
Returns the current hook function.
|
static Function<? super Scheduler,? extends Scheduler> |
RxJavaPlugins.getIoSchedulerHandler()
Returns the current hook function.
|
static Function<? super Scheduler,? extends Scheduler> |
RxJavaPlugins.getNewThreadSchedulerHandler()
Returns the current hook function.
|
static Function<? super Completable,? extends Completable> |
RxJavaPlugins.getOnCompletableAssembly()
Returns the current hook function.
|
static Function<? super ConnectableFlowable,? extends ConnectableFlowable> |
RxJavaPlugins.getOnConnectableFlowableAssembly()
Returns the current hook function.
|
static Function<? super ConnectableObservable,? extends ConnectableObservable> |
RxJavaPlugins.getOnConnectableObservableAssembly()
Returns the current hook function.
|
static Function<? super Flowable,? extends Flowable> |
RxJavaPlugins.getOnFlowableAssembly()
Returns the current hook function.
|
static Function<? super Maybe,? extends Maybe> |
RxJavaPlugins.getOnMaybeAssembly()
Returns the current hook function.
|
static Function<? super Observable,? extends Observable> |
RxJavaPlugins.getOnObservableAssembly()
Returns the current hook function.
|
static Function<? super ParallelFlowable,? extends ParallelFlowable> |
RxJavaPlugins.getOnParallelAssembly()
Returns the current hook function.
|
static Function<? super Single,? extends Single> |
RxJavaPlugins.getOnSingleAssembly()
Returns the current hook function.
|
static Function<? super Runnable,? extends Runnable> |
RxJavaPlugins.getScheduleHandler()
Returns the current hook function.
|
static Function<? super Scheduler,? extends Scheduler> |
RxJavaPlugins.getSingleSchedulerHandler()
Returns the current hook function.
|
Modifier and Type | Method and Description |
---|---|
static void |
RxJavaPlugins.setComputationSchedulerHandler(Function<? super Scheduler,? extends Scheduler> handler)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setInitComputationSchedulerHandler(Function<? super Callable<Scheduler>,? extends Scheduler> handler)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setInitIoSchedulerHandler(Function<? super Callable<Scheduler>,? extends Scheduler> handler)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setInitNewThreadSchedulerHandler(Function<? super Callable<Scheduler>,? extends Scheduler> handler)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setInitSingleSchedulerHandler(Function<? super Callable<Scheduler>,? extends Scheduler> handler)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setIoSchedulerHandler(Function<? super Scheduler,? extends Scheduler> handler)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setNewThreadSchedulerHandler(Function<? super Scheduler,? extends Scheduler> handler)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setOnCompletableAssembly(Function<? super Completable,? extends Completable> onCompletableAssembly)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setOnConnectableFlowableAssembly(Function<? super ConnectableFlowable,? extends ConnectableFlowable> onConnectableFlowableAssembly)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setOnConnectableObservableAssembly(Function<? super ConnectableObservable,? extends ConnectableObservable> onConnectableObservableAssembly)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setOnFlowableAssembly(Function<? super Flowable,? extends Flowable> onFlowableAssembly)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setOnMaybeAssembly(Function<? super Maybe,? extends Maybe> onMaybeAssembly)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setOnObservableAssembly(Function<? super Observable,? extends Observable> onObservableAssembly)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setOnParallelAssembly(Function<? super ParallelFlowable,? extends ParallelFlowable> handler)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setOnSingleAssembly(Function<? super Single,? extends Single> onSingleAssembly)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setScheduleHandler(Function<? super Runnable,? extends Runnable> handler)
Sets the specific hook function.
|
static void |
RxJavaPlugins.setSingleSchedulerHandler(Function<? super Scheduler,? extends Scheduler> handler)
Sets the specific hook function.
|
Copyright © 2019. All rights reserved.