<@NonNull TOpening,@NonNull TClosing> @NonNull Flowable<java.util.List<T>> |
Flowable.buffer(@NonNull org.reactivestreams.Publisher<? extends @NonNull TOpening> openingIndicator,
@NonNull Function<? super @NonNull TOpening,? extends org.reactivestreams.Publisher<? extends @NonNull TClosing>> closingIndicator) |
Returns a Flowable that emits buffers of items it collects from the current Flowable .
|
<@NonNull TOpening,@NonNull TClosing,@NonNull U extends java.util.Collection<? super @NonNull T>> @NonNull Flowable<U> |
Flowable.buffer(@NonNull org.reactivestreams.Publisher<? extends @NonNull TOpening> openingIndicator,
@NonNull Function<? super @NonNull TOpening,? extends org.reactivestreams.Publisher<? extends @NonNull TClosing>> closingIndicator,
@NonNull Supplier<@NonNull U> bufferSupplier) |
Returns a Flowable that emits buffers of items it collects from the current Flowable .
|
<@NonNull TOpening,@NonNull TClosing> @NonNull Observable<@NonNull java.util.List<T>> |
Observable.buffer(@NonNull ObservableSource<? extends @NonNull TOpening> openingIndicator,
@NonNull Function<? super @NonNull TOpening,? extends ObservableSource<? extends @NonNull TClosing>> closingIndicator) |
Returns an Observable that emits buffers of items it collects from the current Observable .
|
<@NonNull TOpening,@NonNull TClosing,@NonNull U extends java.util.Collection<? super @NonNull T>> @NonNull Observable<U> |
Observable.buffer(@NonNull ObservableSource<? extends @NonNull TOpening> openingIndicator,
@NonNull Function<? super @NonNull TOpening,? extends ObservableSource<? extends @NonNull TClosing>> closingIndicator,
@NonNull Supplier<@NonNull U> bufferSupplier) |
Returns an Observable that emits buffers of items it collects from the current Observable .
|
static <@NonNull T,@NonNull R> @NonNull Flowable<R> |
Flowable.combineLatest(@NonNull java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources,
@NonNull Function<? super java.lang.Object[],? extends @NonNull R> combiner) |
Combines a collection of source Publisher s by emitting an item that aggregates the latest values of each of
the source Publisher s each time an item is received from any of the source Publisher s, where this
aggregation is defined by a specified function.
|
static <@NonNull T,@NonNull R> @NonNull Flowable<R> |
Flowable.combineLatest(@NonNull java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources,
@NonNull Function<? super java.lang.Object[],? extends @NonNull R> combiner,
int bufferSize) |
Combines a collection of source Publisher s by emitting an item that aggregates the latest values of each of
the source Publisher s each time an item is received from any of the source Publisher s, where this
aggregation is defined by a specified function.
|
static <@NonNull T,@NonNull R> @NonNull Observable<R> |
Observable.combineLatest(@NonNull java.lang.Iterable<? extends ObservableSource<? extends @NonNull T>> sources,
@NonNull Function<? super java.lang.Object[],? extends @NonNull R> combiner) |
Combines a collection of source ObservableSource s by emitting an item that aggregates the latest values of each of
the returned ObservableSource s each time an item is received from any of the returned ObservableSource s, where this
aggregation is defined by a specified function.
|
static <@NonNull T,@NonNull R> @NonNull Observable<R> |
Observable.combineLatest(@NonNull java.lang.Iterable<? extends ObservableSource<? extends @NonNull T>> sources,
@NonNull Function<? super java.lang.Object[],? extends @NonNull R> combiner,
int bufferSize) |
Combines an Iterable of source ObservableSource s by emitting an item that aggregates the latest values of each of
the returned ObservableSource s each time an item is received from any of the returned ObservableSource s, where this
aggregation is defined by a specified function.
|
static <@NonNull T,@NonNull R> @NonNull Flowable<R> |
Flowable.combineLatestArray(@NonNull org.reactivestreams.Publisher<? extends @NonNull T>[] sources,
@NonNull Function<? super java.lang.Object[],? extends @NonNull R> combiner) |
Combines a collection of source Publisher s by emitting an item that aggregates the latest values of each of
the source Publisher s each time an item is received from any of the source Publisher s, where this
aggregation is defined by a specified function.
|
static <@NonNull T,@NonNull R> @NonNull Flowable<R> |
Flowable.combineLatestArray(@NonNull org.reactivestreams.Publisher<? extends @NonNull T>[] sources,
@NonNull Function<? super java.lang.Object[],? extends @NonNull R> combiner,
int bufferSize) |
Combines a collection of source Publisher s by emitting an item that aggregates the latest values of each of
the source Publisher s each time an item is received from any of the source Publisher s, where this
aggregation is defined by a specified function.
|
static <@NonNull T,@NonNull R> @NonNull Observable<R> |
Observable.combineLatestArray(@NonNull ObservableSource<? extends @NonNull T>[] sources,
@NonNull Function<? super java.lang.Object[],? extends @NonNull R> combiner) |
Combines an array of source ObservableSource s by emitting an item that aggregates the latest values of each of
the ObservableSource s each time an item is received from any of the returned ObservableSource s, where this
aggregation is defined by a specified function.
|
static <@NonNull T,@NonNull R> @NonNull Observable<R> |
Observable.combineLatestArray(@NonNull ObservableSource<? extends @NonNull T>[] sources,
@NonNull Function<? super java.lang.Object[],? extends @NonNull R> combiner,
int bufferSize) |
Combines an array of source ObservableSource s by emitting an item that aggregates the latest values of each of
the ObservableSource s each time an item is received from any of the ObservableSource s, where this
aggregation is defined by a specified function.
|
static <@NonNull T,@NonNull R> @NonNull Flowable<R> |
Flowable.combineLatestArrayDelayError(@NonNull org.reactivestreams.Publisher<? extends @NonNull T>[] sources,
@NonNull Function<? super java.lang.Object[],? extends @NonNull R> combiner) |
Combines a collection of source Publisher s by emitting an item that aggregates the latest values of each of
the source Publisher s each time an item is received from any of the source Publisher s, where this
aggregation is defined by a specified function.
|
static <@NonNull T,@NonNull R> @NonNull Flowable<R> |
Flowable.combineLatestArrayDelayError(@NonNull org.reactivestreams.Publisher<? extends @NonNull T>[] sources,
@NonNull Function<? super java.lang.Object[],? extends @NonNull R> combiner,
int bufferSize) |
Combines a collection of source Publisher s by emitting an item that aggregates the latest values of each of
the source Publisher s each time an item is received from any of the source Publisher s, where this
aggregation is defined by a specified function and delays any error from the sources until
all source Publisher s terminate.
|
static <@NonNull T,@NonNull R> @NonNull Observable<R> |
Observable.combineLatestArrayDelayError(@NonNull ObservableSource<? extends @NonNull T>[] sources,
@NonNull Function<? super java.lang.Object[],? extends @NonNull R> combiner) |
Combines an array of ObservableSource s by emitting an item that aggregates the latest values of each of
the ObservableSource s each time an item is received from any of the ObservableSource s, where this
aggregation is defined by a specified function.
|
static <@NonNull T,@NonNull R> @NonNull Observable<R> |
Observable.combineLatestArrayDelayError(@NonNull ObservableSource<? extends @NonNull T>[] sources,
@NonNull Function<? super java.lang.Object[],? extends @NonNull R> combiner,
int bufferSize) |
Combines an array of ObservableSource s by emitting an item that aggregates the latest values of each of
the ObservableSource s each time an item is received from any of the ObservableSource s, where this
aggregation is defined by a specified function and delays any error from the sources until
all source ObservableSource s terminate.
|
static <@NonNull T,@NonNull R> @NonNull Flowable<R> |
Flowable.combineLatestDelayError(@NonNull java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources,
@NonNull Function<? super java.lang.Object[],? extends @NonNull R> combiner) |
Combines a collection of source Publisher s by emitting an item that aggregates the latest values of each of
the source Publisher s each time an item is received from any of the source Publisher s, where this
aggregation is defined by a specified function and delays any error from the sources until
all source Publisher s terminate.
|
static <@NonNull T,@NonNull R> @NonNull Flowable<R> |
Flowable.combineLatestDelayError(@NonNull java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources,
@NonNull Function<? super java.lang.Object[],? extends @NonNull R> combiner,
int bufferSize) |
Combines a collection of source Publisher s by emitting an item that aggregates the latest values of each of
the source Publisher s each time an item is received from any of the source Publisher s, where this
aggregation is defined by a specified function and delays any error from the sources until
all source Publisher s terminate.
|
static <@NonNull T,@NonNull R> @NonNull Observable<R> |
Observable.combineLatestDelayError(@NonNull java.lang.Iterable<? extends ObservableSource<? extends @NonNull T>> sources,
@NonNull Function<? super java.lang.Object[],? extends @NonNull R> combiner) |
Combines an Iterable of ObservableSource s by emitting an item that aggregates the latest values of each of
the ObservableSource s each time an item is received from any of the ObservableSource s, where this
aggregation is defined by a specified function and delays any error from the sources until
all source ObservableSource s terminate.
|
static <@NonNull T,@NonNull R> @NonNull Observable<R> |
Observable.combineLatestDelayError(@NonNull java.lang.Iterable<? extends ObservableSource<? extends @NonNull T>> sources,
@NonNull Function<? super java.lang.Object[],? extends @NonNull R> combiner,
int bufferSize) |
Combines an Iterable of ObservableSource s by emitting an item that aggregates the latest values of each of
the ObservableSource s each time an item is received from any of the ObservableSource s, where this
aggregation is defined by a specified function and delays any error from the sources until
all source ObservableSource s terminate.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.concatMap(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper) |
Returns a new Flowable that emits items resulting from applying a function that you supply to each item
emitted by the current Flowable , where that function returns a Publisher , and then emitting the items
that result from concatenating those returned Publisher s.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.concatMap(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull 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 current Flowable , where that function returns a Publisher , and then emitting the items
that result from concatenating those returned Publisher s.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.concatMap(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper,
int prefetch,
@NonNull Scheduler scheduler) |
Returns a new Flowable that emits items resulting from applying a function (on a designated scheduler)
that you supply to each item emitted by the current Flowable , where that function returns a Publisher , and then emitting the items
that result from concatenating those returned Publisher s.
|
<@NonNull R> @NonNull Maybe<R> |
Maybe.concatMap(@NonNull Function<? super @NonNull T,? extends MaybeSource<? extends @NonNull R>> mapper) |
Returns a Maybe that is based on applying a specified function to the item emitted by the current Maybe ,
where that function returns a MaybeSource .
|
<@NonNull R> @NonNull Observable<R> |
Observable.concatMap(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull R>> mapper) |
Returns a new Observable that emits items resulting from applying a function that you supply to each item
emitted by the current Observable , where that function returns an ObservableSource , and then emitting the items
that result from concatenating those returned ObservableSource s.
|
<@NonNull R> @NonNull Observable<R> |
Observable.concatMap(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull R>> mapper,
int bufferSize) |
Returns a new Observable that emits items resulting from applying a function that you supply to each item
emitted by the current Observable , where that function returns an ObservableSource , and then emitting the items
that result from concatenating those returned ObservableSource s.
|
<@NonNull R> @NonNull Observable<R> |
Observable.concatMap(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull R>> mapper,
int bufferSize,
@NonNull Scheduler scheduler) |
Returns a new Observable that emits items resulting from applying a function that you supply to each item
emitted by the current Observable , where that function returns an ObservableSource , and then emitting the items
that result from concatenating those returned ObservableSource s.
|
<@NonNull R> @NonNull Single<R> |
Single.concatMap(@NonNull Function<? super @NonNull T,? extends SingleSource<? extends @NonNull R>> mapper) |
Returns a Single that is based on applying a specified function to the item emitted by the current Single ,
where that function returns a SingleSource .
|
@NonNull Completable |
Flowable.concatMapCompletable(@NonNull Function<? super @NonNull T,? extends CompletableSource> mapper) |
Maps the upstream items into CompletableSource s and subscribes to them one after the
other completes.
|
@NonNull Completable |
Flowable.concatMapCompletable(@NonNull Function<? super @NonNull T,? extends CompletableSource> mapper,
int prefetch) |
Maps the upstream items into CompletableSource s and subscribes to them one after the
other completes.
|
@NonNull Completable |
Maybe.concatMapCompletable(@NonNull Function<? super @NonNull T,? extends CompletableSource> mapper) |
Returns a Completable that completes based on applying a specified function to the item emitted by the
current Maybe , where that function returns a Completable .
|
@NonNull Completable |
Observable.concatMapCompletable(@NonNull Function<? super @NonNull T,? extends CompletableSource> mapper) |
Maps each element of the current Observable into CompletableSource s, subscribes to them one at a time in
order and waits until the upstream and all CompletableSource s complete.
|
@NonNull Completable |
Observable.concatMapCompletable(@NonNull Function<? super @NonNull T,? extends CompletableSource> mapper,
int capacityHint) |
Maps each element of the current Observable into CompletableSource s, subscribes to them one at a time in
order and waits until the upstream and all CompletableSource s complete.
|
@NonNull Completable |
Single.concatMapCompletable(@NonNull Function<? super @NonNull T,? extends CompletableSource> mapper) |
Returns a Completable that completes based on applying a specified function to the item emitted by the
current Single , where that function returns a CompletableSource .
|
@NonNull Completable |
Flowable.concatMapCompletableDelayError(@NonNull Function<? super @NonNull 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.
|
@NonNull Completable |
Flowable.concatMapCompletableDelayError(@NonNull Function<? super @NonNull 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.
|
@NonNull Completable |
Flowable.concatMapCompletableDelayError(@NonNull Function<? super @NonNull 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.
|
@NonNull Completable |
Observable.concatMapCompletableDelayError(@NonNull Function<? super @NonNull 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 the current Observable and all
inner CompletableSource s terminate.
|
@NonNull Completable |
Observable.concatMapCompletableDelayError(@NonNull Function<? super @NonNull 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 the current Observable and all
inner CompletableSource s terminate.
|
@NonNull Completable |
Observable.concatMapCompletableDelayError(@NonNull Function<? super @NonNull T,? extends CompletableSource> mapper,
boolean tillTheEnd,
int bufferSize) |
Maps the upstream items into CompletableSource s and subscribes to them one after the
other terminates, optionally delaying all errors till both the current Observable and all
inner CompletableSource s terminate.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.concatMapDelayError(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull 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 Publisher s
till all of them terminate.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.concatMapDelayError(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper,
boolean tillTheEnd,
int prefetch) |
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 Publisher s
till all of them terminate.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.concatMapDelayError(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper,
boolean tillTheEnd,
int prefetch,
@NonNull Scheduler scheduler) |
Maps each of the upstream items into a Publisher , subscribes to them one after the other,
one at a time and emits their values in order
while executing the mapper function on the designated scheduler, delaying any error from either this or any of the
inner Publisher s till all of them terminate.
|
<@NonNull R> @NonNull Observable<R> |
Observable.concatMapDelayError(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull 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 ObservableSource s
till all of them terminate.
|
<@NonNull R> @NonNull Observable<R> |
Observable.concatMapDelayError(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull R>> mapper,
boolean tillTheEnd,
int bufferSize) |
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 ObservableSource s
till all of them terminate.
|
<@NonNull R> @NonNull Observable<R> |
Observable.concatMapDelayError(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull R>> mapper,
boolean tillTheEnd,
int bufferSize,
@NonNull Scheduler scheduler) |
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 ObservableSource s
till all of them terminate.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.concatMapEager(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper) |
Maps a sequence of values into Publisher s and concatenates these Publisher s eagerly into a single
Publisher .
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.concatMapEager(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper,
int maxConcurrency,
int prefetch) |
Maps a sequence of values into Publisher s and concatenates these Publisher s eagerly into a single
Publisher .
|
<@NonNull R> @NonNull Observable<R> |
Observable.concatMapEager(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull R>> mapper) |
Maps a sequence of values into ObservableSource s and concatenates these ObservableSource s eagerly into a single
Observable sequence.
|
<@NonNull R> @NonNull Observable<R> |
Observable.concatMapEager(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull R>> mapper,
int maxConcurrency,
int bufferSize) |
Maps a sequence of values into ObservableSource s and concatenates these ObservableSource s eagerly into a single
Observable sequence.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.concatMapEagerDelayError(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper,
boolean tillTheEnd) |
Maps a sequence of values into Publisher s and concatenates these Publisher s eagerly into a single
Publisher .
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.concatMapEagerDelayError(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper,
boolean tillTheEnd,
int maxConcurrency,
int prefetch) |
Maps a sequence of values into Publisher s and concatenates these Publisher s eagerly into a single
Flowable sequence.
|
<@NonNull R> @NonNull Observable<R> |
Observable.concatMapEagerDelayError(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull R>> mapper,
boolean tillTheEnd) |
Maps a sequence of values into ObservableSource s and concatenates these ObservableSource s eagerly into a single
Observable sequence.
|
<@NonNull R> @NonNull Observable<R> |
Observable.concatMapEagerDelayError(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull R>> mapper,
boolean tillTheEnd,
int maxConcurrency,
int bufferSize) |
Maps a sequence of values into ObservableSource s and concatenates these ObservableSource s eagerly into a single
Observable sequence.
|
<@NonNull U> @NonNull Flowable<U> |
Flowable.concatMapIterable(@NonNull Function<? super @NonNull T,? extends java.lang.Iterable<? extends @NonNull U>> mapper) |
Returns a Flowable that concatenate each item emitted by the current Flowable with the values in an
Iterable corresponding to that item that is generated by a selector.
|
<@NonNull U> @NonNull Flowable<U> |
Flowable.concatMapIterable(@NonNull Function<? super @NonNull T,? extends java.lang.Iterable<? extends @NonNull U>> mapper,
int prefetch) |
Returns a Flowable that concatenate each item emitted by the current Flowable with the values in an
Iterable corresponding to that item that is generated by a selector.
|
<@NonNull U> @NonNull Observable<U> |
Observable.concatMapIterable(@NonNull Function<? super @NonNull T,? extends java.lang.Iterable<? extends @NonNull U>> mapper) |
Returns an Observable that concatenate each item emitted by the current Observable with the values in an
Iterable corresponding to that item that is generated by a selector.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.concatMapMaybe(@NonNull Function<? super @NonNull T,? extends MaybeSource<? extends @NonNull 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.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.concatMapMaybe(@NonNull Function<? super @NonNull T,? extends MaybeSource<? extends @NonNull 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.
|
<@NonNull R> @NonNull Observable<R> |
Observable.concatMapMaybe(@NonNull Function<? super @NonNull T,? extends MaybeSource<? extends @NonNull 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 the current Observable or the current inner MaybeSource fail.
|
<@NonNull R> @NonNull Observable<R> |
Observable.concatMapMaybe(@NonNull Function<? super @NonNull T,? extends MaybeSource<? extends @NonNull R>> mapper,
int bufferSize) |
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 the current Observable or the current inner MaybeSource fail.
|
<@NonNull R> @NonNull Maybe<R> |
Single.concatMapMaybe(@NonNull Function<? super @NonNull T,? extends MaybeSource<? extends @NonNull R>> mapper) |
Returns a Maybe that is based on applying a specified function to the item emitted by the current Single ,
where that function returns a MaybeSource .
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.concatMapMaybeDelayError(@NonNull Function<? super @NonNull T,? extends MaybeSource<? extends @NonNull 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.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.concatMapMaybeDelayError(@NonNull Function<? super @NonNull T,? extends MaybeSource<? extends @NonNull 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.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.concatMapMaybeDelayError(@NonNull Function<? super @NonNull T,? extends MaybeSource<? extends @NonNull 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.
|
<@NonNull R> @NonNull Observable<R> |
Observable.concatMapMaybeDelayError(@NonNull Function<? super @NonNull T,? extends MaybeSource<? extends @NonNull 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 the current Observable and all inner MaybeSource s terminate.
|
<@NonNull R> @NonNull Observable<R> |
Observable.concatMapMaybeDelayError(@NonNull Function<? super @NonNull T,? extends MaybeSource<? extends @NonNull 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 the current Observable and all inner MaybeSource s terminate.
|
<@NonNull R> @NonNull Observable<R> |
Observable.concatMapMaybeDelayError(@NonNull Function<? super @NonNull T,? extends MaybeSource<? extends @NonNull R>> mapper,
boolean tillTheEnd,
int bufferSize) |
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 the current Observable and all inner MaybeSource s terminate.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.concatMapSingle(@NonNull Function<? super @NonNull T,? extends SingleSource<? extends @NonNull 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.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.concatMapSingle(@NonNull Function<? super @NonNull T,? extends SingleSource<? extends @NonNull 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.
|
<@NonNull R> @NonNull Maybe<R> |
Maybe.concatMapSingle(@NonNull Function<? super @NonNull T,? extends SingleSource<? extends @NonNull R>> mapper) |
Returns a Maybe based on applying a specified function to the item emitted by the
current Maybe , where that function returns a Single .
|
<@NonNull R> @NonNull Observable<R> |
Observable.concatMapSingle(@NonNull Function<? super @NonNull T,? extends SingleSource<? extends @NonNull 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 the current Observable or the current inner SingleSource fail.
|
<@NonNull R> @NonNull Observable<R> |
Observable.concatMapSingle(@NonNull Function<? super @NonNull T,? extends SingleSource<? extends @NonNull R>> mapper,
int bufferSize) |
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 the current Observable or the current inner SingleSource fail.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.concatMapSingleDelayError(@NonNull Function<? super @NonNull T,? extends SingleSource<? extends @NonNull 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.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.concatMapSingleDelayError(@NonNull Function<? super @NonNull T,? extends SingleSource<? extends @NonNull 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.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.concatMapSingleDelayError(@NonNull Function<? super @NonNull T,? extends SingleSource<? extends @NonNull 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.
|
<@NonNull R> @NonNull Observable<R> |
Observable.concatMapSingleDelayError(@NonNull Function<? super @NonNull T,? extends SingleSource<? extends @NonNull 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 the current Observable and all inner SingleSource s terminate.
|
<@NonNull R> @NonNull Observable<R> |
Observable.concatMapSingleDelayError(@NonNull Function<? super @NonNull T,? extends SingleSource<? extends @NonNull 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 the current Observable and all inner SingleSource s terminate.
|
<@NonNull R> @NonNull Observable<R> |
Observable.concatMapSingleDelayError(@NonNull Function<? super @NonNull T,? extends SingleSource<? extends @NonNull R>> mapper,
boolean tillTheEnd,
int bufferSize) |
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 the current Observable and all inner SingleSource s terminate.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.concatMapStream(@NonNull Function<? super @NonNull T,? extends java.util.stream.Stream<? extends @NonNull R>> mapper) |
Maps each upstream item into a Stream and emits the Stream 's items to the downstream in a sequential fashion.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.concatMapStream(@NonNull Function<? super @NonNull T,? extends java.util.stream.Stream<? extends @NonNull R>> mapper,
int prefetch) |
Maps each upstream item into a Stream and emits the Stream 's items to the downstream in a sequential fashion.
|
<@NonNull R> @NonNull Observable<R> |
Observable.concatMapStream(@NonNull Function<? super @NonNull T,? extends java.util.stream.Stream<? extends @NonNull R>> mapper) |
Maps each upstream item into a Stream and emits the Stream 's items to the downstream in a sequential fashion.
|
<@NonNull U> @NonNull Flowable<T> |
Flowable.debounce(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<@NonNull U>> debounceIndicator) |
Returns a Flowable that mirrors the current Flowable , except that it drops items emitted by the
current Flowable that are followed by another item within a computed debounce duration.
|
<@NonNull U> @NonNull Observable<T> |
Observable.debounce(@NonNull Function<? super @NonNull T,? extends ObservableSource<@NonNull U>> debounceIndicator) |
Returns an Observable that mirrors the current Observable , except that it drops items emitted by the
current Observable that are followed by another item within a computed debounce duration
denoted by an item emission or completion from a generated inner ObservableSource for that original item.
|
<@NonNull U> @NonNull Flowable<T> |
Flowable.delay(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<@NonNull U>> itemDelayIndicator) |
Returns a Flowable that delays the emissions of the current Flowable via another Publisher on a
per-item basis.
|
<@NonNull U,@NonNull V> @NonNull Flowable<T> |
Flowable.delay(@NonNull org.reactivestreams.Publisher<@NonNull U> subscriptionIndicator,
@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<@NonNull V>> itemDelayIndicator) |
Returns a Flowable that delays the subscription to and emissions from the current Flowable via another
Publisher on a per-item basis.
|
<@NonNull U,@NonNull V> @NonNull Observable<T> |
Observable.delay(@NonNull ObservableSource<@NonNull U> subscriptionIndicator,
@NonNull Function<? super @NonNull T,? extends ObservableSource<@NonNull V>> itemDelayIndicator) |
Returns an Observable that delays the subscription to and emissions from the current Observable via
ObservableSource s for the subscription itself and on a per-item basis.
|
<@NonNull U> @NonNull Observable<T> |
Observable.delay(@NonNull Function<? super @NonNull T,? extends ObservableSource<@NonNull U>> itemDelayIndicator) |
Returns an Observable that delays the emissions of the current Observable via
a per-item derived ObservableSource 's item emission or termination, on a per source item basis.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.dematerialize(@NonNull Function<? super @NonNull T,@NonNull Notification<@NonNull 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.
|
<@NonNull R> @NonNull Maybe<R> |
Maybe.dematerialize(@NonNull Function<? super @NonNull T,@NonNull Notification<@NonNull R>> selector) |
Maps the Notification success value of the current Maybe back into normal
onSuccess , onError or onComplete signals.
|
<@NonNull R> @NonNull Observable<R> |
Observable.dematerialize(@NonNull Function<? super @NonNull T,Notification<@NonNull 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.
|
<@NonNull R> @NonNull Maybe<R> |
Single.dematerialize(@NonNull Function<? super @NonNull T,@NonNull Notification<@NonNull R>> selector) |
Maps the Notification success value of the current Single back into normal
onSuccess , onError or onComplete signals as a
Maybe source.
|
<@NonNull K> @NonNull Flowable<T> |
Flowable.distinct(@NonNull Function<? super @NonNull T,@NonNull K> keySelector) |
Returns a Flowable that emits all items emitted by the current Flowable 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.
|
<@NonNull K> @NonNull Flowable<T> |
Flowable.distinct(@NonNull Function<? super @NonNull T,@NonNull K> keySelector,
@NonNull Supplier<? extends java.util.Collection<? super @NonNull K>> collectionSupplier) |
Returns a Flowable that emits all items emitted by the current Flowable 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.
|
<@NonNull K> @NonNull Observable<T> |
Observable.distinct(@NonNull Function<? super @NonNull T,@NonNull K> keySelector) |
Returns an Observable that emits all items emitted by the current Observable 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.
|
<@NonNull K> @NonNull Observable<T> |
Observable.distinct(@NonNull Function<? super @NonNull T,@NonNull K> keySelector,
@NonNull Supplier<? extends java.util.Collection<? super @NonNull K>> collectionSupplier) |
Returns an Observable that emits all items emitted by the current Observable 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.
|
<@NonNull K> @NonNull Flowable<T> |
Flowable.distinctUntilChanged(@NonNull Function<? super @NonNull T,@NonNull K> keySelector) |
Returns a Flowable that emits all items emitted by the current Flowable 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.
|
<@NonNull K> @NonNull Observable<T> |
Observable.distinctUntilChanged(@NonNull Function<? super @NonNull T,@NonNull K> keySelector) |
Returns an Observable that emits all items emitted by the current Observable 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.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.flatMap(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper) |
Returns a Flowable that emits items based on applying a function that you supply to each item emitted
by the current Flowable , where that function returns a Publisher , and then merging those resulting
Publisher s and emitting the results of this merger.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.flatMap(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper,
boolean delayErrors) |
Returns a Flowable that emits items based on applying a function that you supply to each item emitted
by the current Flowable , where that function returns a Publisher , and then merging those resulting
Publisher s and emitting the results of this merger.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.flatMap(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull 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 current Flowable , where that function returns a Publisher , and then merging those resulting
Publisher s and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these Publisher s.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.flatMap(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull 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 current Flowable , where that function returns a Publisher , and then merging those resulting
Publisher s and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these Publisher s.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.flatMap(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper,
int maxConcurrency) |
Returns a Flowable that emits items based on applying a function that you supply to each item emitted
by the current Flowable , where that function returns a Publisher , and then merging those resulting
Publisher s and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these Publisher s.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.flatMap(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull R>> onNextMapper,
@NonNull Function<? super java.lang.Throwable,? extends org.reactivestreams.Publisher<? extends @NonNull R>> onErrorMapper,
@NonNull Supplier<? extends org.reactivestreams.Publisher<? extends @NonNull R>> onCompleteSupplier) |
Returns a Flowable that applies a function to each item emitted or notification raised by the current
Flowable and then flattens the Publisher s returned from these functions and emits the resulting items.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.flatMap(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull R>> onNextMapper,
@NonNull Function<java.lang.Throwable,? extends org.reactivestreams.Publisher<? extends @NonNull R>> onErrorMapper,
@NonNull Supplier<? extends org.reactivestreams.Publisher<? extends @NonNull R>> onCompleteSupplier,
int maxConcurrency) |
Returns a Flowable that applies a function to each item emitted or notification raised by the current
Flowable and then flattens the Publisher s returned from these functions and emits the resulting items,
while limiting the maximum number of concurrent subscriptions to these Publisher s.
|
<@NonNull U,@NonNull R> @NonNull Flowable<R> |
Flowable.flatMap(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull U>> mapper,
@NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull R> combiner) |
Returns a Flowable that emits the results of a specified function to the pair of values emitted by the
current Flowable and a specified collection Publisher .
|
<@NonNull U,@NonNull R> @NonNull Flowable<R> |
Flowable.flatMap(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull U>> mapper,
@NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull R> combiner,
boolean delayErrors) |
Returns a Flowable that emits the results of a specified function to the pair of values emitted by the
current Flowable and a specified inner Publisher .
|
<@NonNull U,@NonNull R> @NonNull Flowable<R> |
Flowable.flatMap(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull U>> mapper,
@NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull 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
current Flowable and a specified collection Publisher , while limiting the maximum number of concurrent
subscriptions to these Publisher s.
|
<@NonNull U,@NonNull R> @NonNull Flowable<R> |
Flowable.flatMap(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull U>> mapper,
@NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull 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
current Flowable and a specified collection Publisher , while limiting the maximum number of concurrent
subscriptions to these Publisher s.
|
<@NonNull U,@NonNull R> @NonNull Flowable<R> |
Flowable.flatMap(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull U>> mapper,
@NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull R> combiner,
int maxConcurrency) |
Returns a Flowable that emits the results of a specified function to the pair of values emitted by the
current Flowable and a specified collection Publisher , while limiting the maximum number of concurrent
subscriptions to these Publisher s.
|
<@NonNull R> @NonNull Maybe<R> |
Maybe.flatMap(@NonNull Function<? super @NonNull T,? extends MaybeSource<? extends @NonNull R>> mapper) |
Returns a Maybe that is based on applying a specified function to the item emitted by the current Maybe ,
where that function returns a MaybeSource .
|
<@NonNull R> @NonNull Maybe<R> |
Maybe.flatMap(@NonNull Function<? super @NonNull T,? extends MaybeSource<? extends @NonNull R>> onSuccessMapper,
@NonNull Function<? super java.lang.Throwable,? extends MaybeSource<? extends @NonNull R>> onErrorMapper,
@NonNull Supplier<? extends MaybeSource<? extends @NonNull R>> onCompleteSupplier) |
Maps the onSuccess , onError or onComplete signals of the current Maybe into a MaybeSource and emits that
MaybeSource 's signals.
|
<@NonNull U,@NonNull R> @NonNull Maybe<R> |
Maybe.flatMap(@NonNull Function<? super @NonNull T,? extends MaybeSource<? extends @NonNull U>> mapper,
@NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull R> combiner) |
Returns a Maybe that emits the results of a specified function to the pair of values emitted by the
current Maybe and a specified mapped MaybeSource .
|
<@NonNull R> @NonNull Observable<R> |
Observable.flatMap(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull R>> mapper) |
Returns an Observable that emits items based on applying a function that you supply to each item emitted
by the current Observable , where that function returns an ObservableSource , and then merging those returned
ObservableSource s and emitting the results of this merger.
|
<@NonNull R> @NonNull Observable<R> |
Observable.flatMap(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull R>> mapper,
boolean delayErrors) |
Returns an Observable that emits items based on applying a function that you supply to each item emitted
by the current Observable , where that function returns an ObservableSource , and then merging those returned
ObservableSource s and emitting the results of this merger.
|
<@NonNull R> @NonNull Observable<R> |
Observable.flatMap(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull 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 current Observable , where that function returns an ObservableSource , and then merging those returned
ObservableSource s and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these ObservableSource s.
|
<@NonNull R> @NonNull Observable<R> |
Observable.flatMap(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull 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 current Observable , where that function returns an ObservableSource , and then merging those returned
ObservableSource s and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these ObservableSource s.
|
<@NonNull R> @NonNull Observable<R> |
Observable.flatMap(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull R>> mapper,
int maxConcurrency) |
Returns an Observable that emits items based on applying a function that you supply to each item emitted
by the current Observable , where that function returns an ObservableSource , and then merging those returned
ObservableSource s and emitting the results of this merger, while limiting the maximum number of concurrent
subscriptions to these ObservableSource s.
|
<@NonNull R> @NonNull Observable<R> |
Observable.flatMap(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull R>> onNextMapper,
@NonNull Function<? super java.lang.Throwable,? extends ObservableSource<? extends @NonNull R>> onErrorMapper,
@NonNull Supplier<? extends ObservableSource<? extends @NonNull R>> onCompleteSupplier) |
Returns an Observable that applies a function to each item emitted or notification raised by the current
Observable and then flattens the ObservableSource s returned from these functions and emits the resulting items.
|
<@NonNull R> @NonNull Observable<R> |
Observable.flatMap(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull R>> onNextMapper,
@NonNull Function<java.lang.Throwable,? extends ObservableSource<? extends @NonNull R>> onErrorMapper,
@NonNull Supplier<? extends ObservableSource<? extends @NonNull R>> onCompleteSupplier,
int maxConcurrency) |
Returns an Observable that applies a function to each item emitted or notification raised by the current
Observable and then flattens the ObservableSource s returned from these functions and emits the resulting items,
while limiting the maximum number of concurrent subscriptions to these ObservableSource s.
|
<@NonNull U,@NonNull R> @NonNull Observable<R> |
Observable.flatMap(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull U>> mapper,
@NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull R> combiner) |
Returns an Observable that emits the results of a specified function to the pair of values emitted by the
current Observable and the mapped inner ObservableSource .
|
<@NonNull U,@NonNull R> @NonNull Observable<R> |
Observable.flatMap(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull U>> mapper,
@NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull R> combiner,
boolean delayErrors) |
Returns an Observable that emits the results of a specified function to the pair of values emitted by the
current Observable and the mapped inner ObservableSource .
|
<@NonNull U,@NonNull R> @NonNull Observable<R> |
Observable.flatMap(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull U>> mapper,
@NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull 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
current Observable and the mapped inner ObservableSource , while limiting the maximum number of concurrent
subscriptions to these ObservableSource s.
|
<@NonNull U,@NonNull R> @NonNull Observable<R> |
Observable.flatMap(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull U>> mapper,
@NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull 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
current Observable and the mapped inner ObservableSource , while limiting the maximum number of concurrent
subscriptions to these ObservableSource s.
|
<@NonNull U,@NonNull R> @NonNull Observable<R> |
Observable.flatMap(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull U>> mapper,
@NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull R> combiner,
int maxConcurrency) |
Returns an Observable that emits the results of a specified function to the pair of values emitted by the
current Observable and the mapped inner ObservableSource , while limiting the maximum number of concurrent
subscriptions to these ObservableSource s.
|
<@NonNull R> @NonNull Single<R> |
Single.flatMap(@NonNull Function<? super @NonNull T,? extends SingleSource<? extends @NonNull R>> mapper) |
Returns a Single that is based on applying a specified function to the item emitted by the current Single ,
where that function returns a SingleSource .
|
<@NonNull R> @NonNull Single<R> |
Single.flatMap(@NonNull Function<? super @NonNull T,? extends SingleSource<? extends @NonNull R>> onSuccessMapper,
@NonNull Function<? super java.lang.Throwable,? extends SingleSource<? extends @NonNull R>> onErrorMapper) |
Maps the onSuccess or onError signals of the current Single into a SingleSource and emits that
SingleSource 's signals.
|
<@NonNull U,@NonNull R> @NonNull Single<R> |
Single.flatMap(@NonNull Function<? super @NonNull T,? extends SingleSource<? extends @NonNull U>> mapper,
@NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull R> combiner) |
Returns a Single that emits the results of a specified function to the pair of values emitted by the
current Single and a specified mapped SingleSource .
|
@NonNull Completable |
Flowable.flatMapCompletable(@NonNull Function<? super @NonNull T,? extends CompletableSource> mapper) |
Maps each element of the upstream Flowable into CompletableSource s, subscribes to them and
waits until the upstream and all CompletableSource s complete.
|
@NonNull Completable |
Flowable.flatMapCompletable(@NonNull Function<? super @NonNull T,? extends CompletableSource> mapper,
boolean delayErrors,
int maxConcurrency) |
Maps each element of the upstream Flowable into CompletableSource s, subscribes to them and
waits until the upstream and all CompletableSource s complete, optionally delaying all errors.
|
@NonNull Completable |
Maybe.flatMapCompletable(@NonNull Function<? super @NonNull T,? extends CompletableSource> mapper) |
Returns a Completable that completes based on applying a specified function to the item emitted by the
current Maybe , where that function returns a Completable .
|
@NonNull Completable |
Observable.flatMapCompletable(@NonNull Function<? super @NonNull T,? extends CompletableSource> mapper) |
Maps each element of the current Observable into CompletableSource s, subscribes to them and
waits until the upstream and all CompletableSource s complete.
|
@NonNull Completable |
Observable.flatMapCompletable(@NonNull Function<? super @NonNull T,? extends CompletableSource> mapper,
boolean delayErrors) |
Maps each element of the current Observable into CompletableSource s, subscribes to them and
waits until the upstream and all CompletableSource s complete, optionally delaying all errors.
|
@NonNull Completable |
Single.flatMapCompletable(@NonNull Function<? super @NonNull T,? extends CompletableSource> mapper) |
Returns a Completable that completes based on applying a specified function to the item emitted by the
current Single , where that function returns a CompletableSource .
|
<@NonNull U> @NonNull Flowable<U> |
Flowable.flatMapIterable(@NonNull Function<? super @NonNull T,? extends java.lang.Iterable<? extends @NonNull U>> mapper) |
Merges Iterable s generated by a mapper Function for each individual item emitted by
the current Flowable into a single Flowable sequence.
|
<@NonNull U> @NonNull Flowable<U> |
Flowable.flatMapIterable(@NonNull Function<? super @NonNull T,? extends java.lang.Iterable<? extends @NonNull U>> mapper,
int bufferSize) |
Merges Iterable s generated by a mapper Function for each individual item emitted by
the current Flowable into a single Flowable sequence.
|
<@NonNull U,@NonNull V> @NonNull Flowable<V> |
Flowable.flatMapIterable(@NonNull Function<? super @NonNull T,? extends java.lang.Iterable<? extends @NonNull U>> mapper,
@NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull V> combiner) |
Merges Iterable s generated by a mapper Function for each individual item emitted by
the current Flowable into a single Flowable sequence where the resulting items will
be the combination of the original item and each inner item of the respective Iterable as returned
by the resultSelector BiFunction .
|
<@NonNull U,@NonNull V> @NonNull Flowable<V> |
Flowable.flatMapIterable(@NonNull Function<? super @NonNull T,? extends java.lang.Iterable<? extends @NonNull U>> mapper,
@NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull V> combiner,
int prefetch) |
Merges Iterable s generated by a mapper Function for each individual item emitted by
the current Flowable into a single Flowable sequence where the resulting items will
be the combination of the original item and each inner item of the respective Iterable as returned
by the resultSelector BiFunction .
|
<@NonNull U> @NonNull Observable<U> |
Observable.flatMapIterable(@NonNull Function<? super @NonNull T,? extends java.lang.Iterable<? extends @NonNull U>> mapper) |
Merges Iterable s generated by a mapper Function for each individual item emitted by
the current Observable into a single Observable sequence.
|
<@NonNull U,@NonNull V> @NonNull Observable<V> |
Observable.flatMapIterable(@NonNull Function<? super @NonNull T,? extends java.lang.Iterable<? extends @NonNull U>> mapper,
@NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull V> combiner) |
Merges Iterable s generated by a mapper Function for each individual item emitted by
the current Observable into a single Observable sequence where the resulting items will
be the combination of the original item and each inner item of the respective Iterable as returned
by the resultSelector BiFunction .
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.flatMapMaybe(@NonNull Function<? super @NonNull T,? extends MaybeSource<? extends @NonNull R>> mapper) |
Maps each element of the upstream Flowable into MaybeSource s, subscribes to all of them
and merges their onSuccess values, in no particular order, into a single Flowable sequence.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.flatMapMaybe(@NonNull Function<? super @NonNull T,? extends MaybeSource<? extends @NonNull R>> mapper,
boolean delayErrors,
int maxConcurrency) |
Maps each element of the upstream Flowable into MaybeSource s, subscribes to at most
maxConcurrency MaybeSource s at a time and merges their onSuccess values,
in no particular order, into a single Flowable sequence, optionally delaying all errors.
|
<@NonNull R> @NonNull Observable<R> |
Observable.flatMapMaybe(@NonNull Function<? super @NonNull T,? extends MaybeSource<? extends @NonNull R>> mapper) |
Maps each element of the current Observable into MaybeSource s, subscribes to all of them
and merges their onSuccess values, in no particular order, into a single Observable sequence.
|
<@NonNull R> @NonNull Observable<R> |
Observable.flatMapMaybe(@NonNull Function<? super @NonNull T,? extends MaybeSource<? extends @NonNull R>> mapper,
boolean delayErrors) |
Maps each element of the current Observable into MaybeSource s, subscribes to them
and merges their onSuccess values, in no particular order, into a single Observable sequence,
optionally delaying all errors.
|
<@NonNull R> @NonNull Maybe<R> |
Single.flatMapMaybe(@NonNull Function<? super @NonNull T,? extends MaybeSource<? extends @NonNull R>> mapper) |
Returns a Maybe that is based on applying a specified function to the item emitted by the current Single ,
where that function returns a MaybeSource .
|
<@NonNull R> @NonNull Observable<R> |
Maybe.flatMapObservable(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull R>> mapper) |
Returns an Observable that is based on applying a specified function to the item emitted by the current Maybe ,
where that function returns an ObservableSource .
|
<@NonNull R> @NonNull Observable<R> |
Single.flatMapObservable(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull R>> mapper) |
Returns an Observable that is based on applying a specified function to the item emitted by the current Single ,
where that function returns an ObservableSource .
|
<@NonNull R> @NonNull Flowable<R> |
Maybe.flatMapPublisher(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper) |
Returns a Flowable that emits items based on applying a specified function to the item emitted by the
current Maybe , where that function returns a Publisher .
|
<@NonNull R> @NonNull Flowable<R> |
Single.flatMapPublisher(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper) |
Returns a Flowable that emits items based on applying a specified function to the item emitted by the
current Single , where that function returns a Publisher .
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.flatMapSingle(@NonNull Function<? super @NonNull T,? extends SingleSource<? extends @NonNull R>> mapper) |
Maps each element of the upstream Flowable into SingleSource s, subscribes to all of them
and merges their onSuccess values, in no particular order, into a single Flowable sequence.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.flatMapSingle(@NonNull Function<? super @NonNull T,? extends SingleSource<? extends @NonNull R>> mapper,
boolean delayErrors,
int maxConcurrency) |
Maps each element of the upstream Flowable into SingleSource s, subscribes to at most
maxConcurrency SingleSource s at a time and merges their onSuccess values,
in no particular order, into a single Flowable sequence, optionally delaying all errors.
|
<@NonNull R> @NonNull Maybe<R> |
Maybe.flatMapSingle(@NonNull Function<? super @NonNull T,? extends SingleSource<? extends @NonNull R>> mapper) |
Returns a Maybe based on applying a specified function to the item emitted by the
current Maybe , where that function returns a Single .
|
<@NonNull R> @NonNull Observable<R> |
Observable.flatMapSingle(@NonNull Function<? super @NonNull T,? extends SingleSource<? extends @NonNull R>> mapper) |
Maps each element of the current Observable into SingleSource s, subscribes to all of them
and merges their onSuccess values, in no particular order, into a single Observable sequence.
|
<@NonNull R> @NonNull Observable<R> |
Observable.flatMapSingle(@NonNull Function<? super @NonNull T,? extends SingleSource<? extends @NonNull R>> mapper,
boolean delayErrors) |
Maps each element of the current Observable into SingleSource s, subscribes to them
and merges their onSuccess values, in no particular order, into a single Observable sequence,
optionally delaying all errors.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.flatMapStream(@NonNull Function<? super @NonNull T,? extends java.util.stream.Stream<? extends @NonNull R>> mapper) |
Maps each upstream item into a Stream and emits the Stream 's items to the downstream in a sequential fashion.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.flatMapStream(@NonNull Function<? super @NonNull T,? extends java.util.stream.Stream<? extends @NonNull R>> mapper,
int prefetch) |
Maps each upstream item into a Stream and emits the Stream 's items to the downstream in a sequential fashion.
|
<@NonNull R> @NonNull Observable<R> |
Observable.flatMapStream(@NonNull Function<? super @NonNull T,? extends java.util.stream.Stream<? extends @NonNull R>> mapper) |
Maps each upstream item into a Stream and emits the Stream 's items to the downstream in a sequential fashion.
|
<@NonNull U> @NonNull Flowable<U> |
Maybe.flattenAsFlowable(@NonNull Function<? super @NonNull T,? extends java.lang.Iterable<? extends @NonNull U>> mapper) |
Maps the success value of the current Maybe into an Iterable and emits its items as a
Flowable sequence.
|
<@NonNull U> @NonNull Flowable<U> |
Single.flattenAsFlowable(@NonNull Function<? super @NonNull T,? extends java.lang.Iterable<? extends @NonNull U>> mapper) |
Maps the success value of the current Single into an Iterable and emits its items as a
Flowable sequence.
|
<@NonNull U> @NonNull Observable<U> |
Maybe.flattenAsObservable(@NonNull Function<? super @NonNull T,? extends java.lang.Iterable<? extends @NonNull U>> mapper) |
Maps the success value of the current Maybe into an Iterable and emits its items as an
Observable sequence.
|
<@NonNull U> @NonNull Observable<U> |
Single.flattenAsObservable(@NonNull Function<? super @NonNull T,? extends java.lang.Iterable<? extends @NonNull U>> mapper) |
Maps the success value of the current Single into an Iterable and emits its items as an
Observable sequence.
|
<@NonNull R> @NonNull Flowable<R> |
Maybe.flattenStreamAsFlowable(@NonNull Function<? super @NonNull T,? extends java.util.stream.Stream<? extends @NonNull R>> mapper) |
Maps the upstream succecss value into a Java Stream and emits its
items to the downstream consumer as a Flowable .
|
<@NonNull R> @NonNull Flowable<R> |
Single.flattenStreamAsFlowable(@NonNull Function<? super @NonNull T,? extends java.util.stream.Stream<? extends @NonNull R>> mapper) |
Maps the upstream succecss value into a Java Stream and emits its
items to the downstream consumer as a Flowable .
|
<@NonNull R> @NonNull Observable<R> |
Maybe.flattenStreamAsObservable(@NonNull Function<? super @NonNull T,? extends java.util.stream.Stream<? extends @NonNull R>> mapper) |
Maps the upstream succecss value into a Java Stream and emits its
items to the downstream consumer as an Observable .
|
<@NonNull R> @NonNull Observable<R> |
Single.flattenStreamAsObservable(@NonNull Function<? super @NonNull T,? extends java.util.stream.Stream<? extends @NonNull R>> mapper) |
Maps the upstream succecss value into a Java Stream and emits its
items to the downstream consumer as an Observable .
|
<@NonNull K> @NonNull Flowable<GroupedFlowable<K,T>> |
Flowable.groupBy(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector) |
Groups the items emitted by the current Flowable according to a specified criterion, and emits these
grouped items as GroupedFlowable s.
|
<@NonNull K> @NonNull Flowable<GroupedFlowable<K,T>> |
Flowable.groupBy(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector,
boolean delayError) |
Groups the items emitted by the current Flowable according to a specified criterion, and emits these
grouped items as GroupedFlowable s.
|
<@NonNull K,@NonNull V> @NonNull Flowable<GroupedFlowable<K,V>> |
Flowable.groupBy(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector,
@NonNull Function<? super @NonNull T,? extends @NonNull V> valueSelector) |
Groups the items emitted by the current Flowable according to a specified criterion, and emits these
grouped items as GroupedFlowable s.
|
<@NonNull K,@NonNull V> @NonNull Flowable<GroupedFlowable<K,V>> |
Flowable.groupBy(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector,
@NonNull Function<? super @NonNull T,? extends @NonNull V> valueSelector,
boolean delayError) |
Groups the items emitted by the current Flowable according to a specified criterion, and emits these
grouped items as GroupedFlowable s.
|
<@NonNull K,@NonNull V> @NonNull Flowable<GroupedFlowable<K,V>> |
Flowable.groupBy(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector,
@NonNull Function<? super @NonNull T,? extends @NonNull V> valueSelector,
boolean delayError,
int bufferSize) |
Groups the items emitted by the current Flowable according to a specified criterion, and emits these
grouped items as GroupedFlowable s.
|
<@NonNull K,@NonNull V> @NonNull Flowable<GroupedFlowable<K,V>> |
Flowable.groupBy(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector,
@NonNull Function<? super @NonNull T,? extends @NonNull V> valueSelector,
boolean delayError,
int bufferSize,
@NonNull Function<? super Consumer<java.lang.Object>,? extends java.util.Map<@NonNull K,java.lang.Object>> evictingMapFactory) |
Groups the items emitted by the current Flowable according to a specified criterion, and emits these
grouped items as GroupedFlowable s.
|
<@NonNull K> @NonNull Observable<GroupedObservable<K,T>> |
Observable.groupBy(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector) |
Groups the items emitted by the current Observable according to a specified criterion, and emits these
grouped items as GroupedObservable s.
|
<@NonNull K> @NonNull Observable<GroupedObservable<K,T>> |
Observable.groupBy(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector,
boolean delayError) |
Groups the items emitted by the current Observable according to a specified criterion, and emits these
grouped items as GroupedObservable s.
|
<@NonNull K,@NonNull V> @NonNull Observable<GroupedObservable<K,V>> |
Observable.groupBy(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector,
@NonNull Function<? super @NonNull T,? extends @NonNull V> valueSelector,
boolean delayError) |
Groups the items emitted by the current Observable according to a specified criterion, and emits these
grouped items as GroupedObservable s.
|
<@NonNull K,@NonNull V> @NonNull Observable<GroupedObservable<K,V>> |
Observable.groupBy(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector,
@NonNull Function<? super @NonNull T,? extends @NonNull V> valueSelector,
boolean delayError,
int bufferSize) |
Groups the items emitted by the current Observable according to a specified criterion, and emits these
grouped items as GroupedObservable s.
|
<@NonNull K,@NonNull V> @NonNull Observable<GroupedObservable<K,V>> |
Observable.groupBy(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector,
Function<? super @NonNull T,? extends @NonNull V> valueSelector) |
Groups the items emitted by the current Observable according to a specified criterion, and emits these
grouped items as GroupedObservable s.
|
<@NonNull TRight,@NonNull TLeftEnd,@NonNull TRightEnd,@NonNull R> @NonNull Flowable<R> |
Flowable.groupJoin(@NonNull org.reactivestreams.Publisher<? extends @NonNull TRight> other,
@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<@NonNull TLeftEnd>> leftEnd,
@NonNull Function<? super @NonNull TRight,? extends org.reactivestreams.Publisher<@NonNull TRightEnd>> rightEnd,
@NonNull BiFunction<? super @NonNull T,? super Flowable<@NonNull TRight>,? extends @NonNull R> resultSelector) |
Returns a Flowable that correlates two Publisher s when they overlap in time and groups the results.
|
<@NonNull TRight,@NonNull TLeftEnd,@NonNull TRightEnd,@NonNull R> @NonNull Observable<R> |
Observable.groupJoin(@NonNull ObservableSource<? extends @NonNull TRight> other,
@NonNull Function<? super @NonNull T,? extends ObservableSource<@NonNull TLeftEnd>> leftEnd,
@NonNull Function<? super @NonNull TRight,? extends ObservableSource<@NonNull TRightEnd>> rightEnd,
@NonNull BiFunction<? super @NonNull T,? super Observable<@NonNull TRight>,? extends @NonNull R> resultSelector) |
Returns an Observable that correlates two ObservableSource s when they overlap in time and groups the results.
|
<@NonNull TRight,@NonNull TLeftEnd,@NonNull TRightEnd,@NonNull R> @NonNull Flowable<R> |
Flowable.join(@NonNull org.reactivestreams.Publisher<? extends @NonNull TRight> other,
@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<@NonNull TLeftEnd>> leftEnd,
@NonNull Function<? super @NonNull TRight,? extends org.reactivestreams.Publisher<@NonNull TRightEnd>> rightEnd,
@NonNull BiFunction<? super @NonNull T,? super @NonNull TRight,? extends @NonNull R> resultSelector) |
Correlates the items emitted by two Publisher s based on overlapping durations.
|
<@NonNull TRight,@NonNull TLeftEnd,@NonNull TRightEnd,@NonNull R> @NonNull Observable<R> |
Observable.join(@NonNull ObservableSource<? extends @NonNull TRight> other,
@NonNull Function<? super @NonNull T,? extends ObservableSource<@NonNull TLeftEnd>> leftEnd,
@NonNull Function<? super @NonNull TRight,? extends ObservableSource<@NonNull TRightEnd>> rightEnd,
@NonNull BiFunction<? super @NonNull T,? super @NonNull TRight,? extends @NonNull R> resultSelector) |
Correlates the items emitted by two ObservableSource s based on overlapping durations.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.map(@NonNull Function<? super @NonNull T,? extends @NonNull R> mapper) |
Returns a Flowable that applies a specified function to each item emitted by the current Flowable and
emits the results of these function applications.
|
<@NonNull R> @NonNull Maybe<R> |
Maybe.map(@NonNull Function<? super @NonNull T,? extends @NonNull R> mapper) |
Returns a Maybe that applies a specified function to the item emitted by the current Maybe and
emits the result of this function application.
|
<@NonNull R> @NonNull Observable<R> |
Observable.map(@NonNull Function<? super @NonNull T,? extends @NonNull R> mapper) |
Returns an Observable that applies a specified function to each item emitted by the current Observable and
emits the results of these function applications.
|
<@NonNull R> @NonNull Single<R> |
Single.map(@NonNull Function<? super @NonNull T,? extends @NonNull R> mapper) |
Returns a Single that applies a specified function to the item emitted by the current Single and
emits the result of this function application.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.mapOptional(@NonNull Function<? super @NonNull T,@NonNull java.util.Optional<? extends @NonNull R>> mapper) |
Maps each upstream value into an Optional and emits the contained item if not empty.
|
<@NonNull R> @NonNull Maybe<R> |
Maybe.mapOptional(@NonNull Function<? super @NonNull T,@NonNull java.util.Optional<? extends @NonNull R>> mapper) |
Maps the upstream success value into an Optional and emits the contained item if not empty.
|
<@NonNull R> @NonNull Observable<R> |
Observable.mapOptional(@NonNull Function<? super @NonNull T,@NonNull java.util.Optional<? extends @NonNull R>> mapper) |
Maps each upstream value into an Optional and emits the contained item if not empty.
|
<@NonNull R> @NonNull Maybe<R> |
Single.mapOptional(@NonNull Function<? super @NonNull T,@NonNull java.util.Optional<? extends @NonNull R>> mapper) |
Maps the upstream success value into an Optional and emits the contained item if not empty as a Maybe .
|
@NonNull Completable |
Completable.onErrorResumeNext(@NonNull Function<? super java.lang.Throwable,? extends CompletableSource> fallbackSupplier) |
Returns a Completable instance that when encounters an error from this Completable , calls the
specified mapper Function that returns a CompletableSource instance for it and resumes the
execution with it.
|
@NonNull Flowable<T> |
Flowable.onErrorResumeNext(@NonNull Function<? super java.lang.Throwable,? extends org.reactivestreams.Publisher<? extends @NonNull T>> fallbackSupplier) |
Resumes the flow with a Publisher returned for the failure Throwable of the current Flowable by a
function instead of signaling the error via onError .
|
@NonNull Maybe<T> |
Maybe.onErrorResumeNext(@NonNull Function<? super java.lang.Throwable,? extends MaybeSource<? extends @NonNull T>> fallbackSupplier) |
Resumes the flow with a MaybeSource returned for the failure Throwable of the current Maybe by a
function instead of signaling the error via onError .
|
@NonNull Observable<T> |
Observable.onErrorResumeNext(@NonNull Function<? super java.lang.Throwable,? extends ObservableSource<? extends @NonNull T>> fallbackSupplier) |
Resumes the flow with an ObservableSource returned for the failure Throwable of the current Observable by a
function instead of signaling the error via onError .
|
@NonNull Single<T> |
Single.onErrorResumeNext(@NonNull Function<? super java.lang.Throwable,? extends SingleSource<? extends @NonNull T>> fallbackSupplier) |
Resumes the flow with a SingleSource returned for the failure Throwable of the current Single by a
function instead of signaling the error via onError .
|
<@NonNull T> @NonNull Maybe<T> |
Completable.onErrorReturn(@NonNull Function<? super java.lang.Throwable,? extends @NonNull T> itemSupplier) |
Ends the flow with a success item returned by a function for the Throwable error signaled by the current
Completable instead of signaling the error via onError .
|
@NonNull Flowable<T> |
Flowable.onErrorReturn(@NonNull Function<? super java.lang.Throwable,? extends @NonNull T> itemSupplier) |
Ends the flow with a last item returned by a function for the Throwable error signaled by the current
Flowable instead of signaling the error via onError .
|
@NonNull Maybe<T> |
Maybe.onErrorReturn(@NonNull Function<? super java.lang.Throwable,? extends @NonNull T> itemSupplier) |
Ends the flow with a success item returned by a function for the Throwable error signaled by the current
Maybe instead of signaling the error via onError .
|
@NonNull Observable<T> |
Observable.onErrorReturn(@NonNull Function<? super java.lang.Throwable,? extends @NonNull T> itemSupplier) |
Ends the flow with a last item returned by a function for the Throwable error signaled by the current
Observable instead of signaling the error via onError .
|
@NonNull Single<T> |
Single.onErrorReturn(@NonNull Function<java.lang.Throwable,? extends @NonNull T> itemSupplier) |
Ends the flow with a success item returned by a function for the Throwable error signaled by the current
Single instead of signaling the error via onError .
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.publish(@NonNull Function<? super Flowable<@NonNull T>,? extends org.reactivestreams.Publisher<? extends @NonNull 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.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.publish(@NonNull Function<? super Flowable<@NonNull T>,? extends org.reactivestreams.Publisher<@NonNull 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.
|
<@NonNull R> @NonNull Observable<R> |
Observable.publish(@NonNull Function<? super Observable<@NonNull T>,? extends ObservableSource<@NonNull 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 current Observable sequence.
|
@NonNull Completable |
Completable.repeatWhen(@NonNull Function<? super Flowable<java.lang.Object>,? extends org.reactivestreams.Publisher<?>> handler) |
Returns a Completable instance that repeats when the Publisher returned by the handler Function
emits an item or completes when this Publisher emits an onComplete event.
|
@NonNull Flowable<T> |
Flowable.repeatWhen(@NonNull Function<? super Flowable<java.lang.Object>,? extends org.reactivestreams.Publisher<?>> handler) |
Returns a Flowable that emits the same values as the current Flowable with the exception of an
onComplete .
|
@NonNull Flowable<T> |
Maybe.repeatWhen(@NonNull Function<? super Flowable<java.lang.Object>,? extends org.reactivestreams.Publisher<?>> handler) |
Returns a Flowable that emits the same values as the current Maybe with the exception of an
onComplete .
|
@NonNull Observable<T> |
Observable.repeatWhen(@NonNull Function<? super Observable<java.lang.Object>,? extends ObservableSource<?>> handler) |
Returns an Observable that emits the same values as the current Observable with the exception of an
onComplete .
|
@NonNull Flowable<T> |
Single.repeatWhen(@NonNull Function<? super Flowable<java.lang.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 signaled through the Flowable the handler receives.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.replay(@NonNull Function<? super Flowable<@NonNull T>,? extends org.reactivestreams.Publisher<@NonNull 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 current Flowable .
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.replay(@NonNull Function<? super Flowable<@NonNull T>,? extends org.reactivestreams.Publisher<@NonNull 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 current Flowable ,
replaying bufferSize notifications.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.replay(@NonNull Function<? super Flowable<@NonNull T>,? extends org.reactivestreams.Publisher<@NonNull R>> selector,
int bufferSize,
boolean eagerTruncate) |
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 current Flowable ,
replaying bufferSize notifications.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.replay(@NonNull Function<? super Flowable<@NonNull T>,? extends org.reactivestreams.Publisher<@NonNull R>> selector,
int bufferSize,
long time,
@NonNull java.util.concurrent.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 current Flowable ,
replaying no more than bufferSize items that were emitted within a specified time window.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.replay(@NonNull Function<? super Flowable<@NonNull T>,? extends org.reactivestreams.Publisher<@NonNull R>> selector,
int bufferSize,
long time,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull 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 current Flowable ,
replaying no more than bufferSize items that were emitted within a specified time window.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.replay(@NonNull Function<? super Flowable<@NonNull T>,? extends org.reactivestreams.Publisher<@NonNull R>> selector,
int bufferSize,
long time,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
boolean eagerTruncate) |
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 current Flowable ,
replaying no more than bufferSize items that were emitted within a specified time window.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.replay(@NonNull Function<? super Flowable<@NonNull T>,? extends org.reactivestreams.Publisher<@NonNull R>> selector,
long time,
@NonNull java.util.concurrent.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 current Flowable ,
replaying all items that were emitted within a specified time window.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.replay(@NonNull Function<? super Flowable<@NonNull T>,? extends org.reactivestreams.Publisher<@NonNull R>> selector,
long time,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull 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 current Flowable ,
replaying all items that were emitted within a specified time window.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.replay(@NonNull Function<? super Flowable<@NonNull T>,? extends org.reactivestreams.Publisher<@NonNull R>> selector,
long time,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
boolean eagerTruncate) |
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 current Flowable ,
replaying all items that were emitted within a specified time window.
|
<@NonNull R> @NonNull Observable<R> |
Observable.replay(@NonNull Function<? super Observable<@NonNull T>,? extends ObservableSource<@NonNull 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 current Observable .
|
<@NonNull R> @NonNull Observable<R> |
Observable.replay(@NonNull Function<? super Observable<@NonNull T>,? extends ObservableSource<@NonNull 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 current Observable ,
replaying bufferSize notifications.
|
<@NonNull R> @NonNull Observable<R> |
Observable.replay(@NonNull Function<? super Observable<@NonNull T>,? extends ObservableSource<@NonNull R>> selector,
int bufferSize,
boolean eagerTruncate) |
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 current Observable ,
replaying bufferSize notifications.
|
<@NonNull R> @NonNull Observable<R> |
Observable.replay(@NonNull Function<? super Observable<@NonNull T>,? extends ObservableSource<@NonNull R>> selector,
int bufferSize,
long time,
@NonNull java.util.concurrent.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 current Observable ,
replaying no more than bufferSize items that were emitted within a specified time window.
|
<@NonNull R> @NonNull Observable<R> |
Observable.replay(@NonNull Function<? super Observable<@NonNull T>,? extends ObservableSource<@NonNull R>> selector,
int bufferSize,
long time,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull 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 current Observable ,
replaying no more than bufferSize items that were emitted within a specified time window.
|
<@NonNull R> @NonNull Observable<R> |
Observable.replay(@NonNull Function<? super Observable<@NonNull T>,? extends ObservableSource<@NonNull R>> selector,
int bufferSize,
long time,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
boolean eagerTruncate) |
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 current Observable ,
replaying no more than bufferSize items that were emitted within a specified time window.
|
<@NonNull R> @NonNull Observable<R> |
Observable.replay(@NonNull Function<? super Observable<@NonNull T>,? extends ObservableSource<@NonNull R>> selector,
long time,
@NonNull java.util.concurrent.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 current Observable ,
replaying all items that were emitted within a specified time window.
|
<@NonNull R> @NonNull Observable<R> |
Observable.replay(@NonNull Function<? super Observable<@NonNull T>,? extends ObservableSource<@NonNull R>> selector,
long time,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull 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 current Observable ,
replaying all items that were emitted within a specified time window.
|
<@NonNull R> @NonNull Observable<R> |
Observable.replay(@NonNull Function<? super Observable<@NonNull T>,? extends ObservableSource<@NonNull R>> selector,
long time,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
boolean eagerTruncate) |
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 current Observable ,
replaying all items that were emitted within a specified time window.
|
@NonNull Completable |
Completable.retryWhen(@NonNull Function<? super Flowable<java.lang.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.
|
@NonNull Flowable<T> |
Flowable.retryWhen(@NonNull Function<? super Flowable<java.lang.Throwable>,? extends org.reactivestreams.Publisher<?>> handler) |
Returns a Flowable that emits the same values as the current Flowable with the exception of an
onError .
|
@NonNull Maybe<T> |
Maybe.retryWhen(@NonNull Function<? super Flowable<java.lang.Throwable>,? extends org.reactivestreams.Publisher<?>> handler) |
Returns a Maybe that emits the same values as the current Maybe with the exception of an
onError .
|
@NonNull Observable<T> |
Observable.retryWhen(@NonNull Function<? super Observable<java.lang.Throwable>,? extends ObservableSource<?>> handler) |
Returns an Observable that emits the same values as the current Observable with the exception of an
onError .
|
@NonNull Single<T> |
Single.retryWhen(@NonNull Function<? super Flowable<java.lang.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.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.switchMap(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper) |
Returns a new Flowable by applying a function that you supply to each item emitted by the current
Flowable that returns a Publisher , and then emitting the items emitted by the most recently emitted
of these Publisher s.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.switchMap(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper,
int bufferSize) |
Returns a new Flowable by applying a function that you supply to each item emitted by the current
Flowable that returns a Publisher , and then emitting the items emitted by the most recently emitted
of these Publisher s.
|
<@NonNull R> @NonNull Observable<R> |
Observable.switchMap(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull R>> mapper) |
Returns a new Observable by applying a function that you supply to each item emitted by the current
Observable that returns an ObservableSource , and then emitting the items emitted by the most recently emitted
of these ObservableSource s.
|
<@NonNull R> @NonNull Observable<R> |
Observable.switchMap(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull R>> mapper,
int bufferSize) |
Returns a new Observable by applying a function that you supply to each item emitted by the current
Observable that returns an ObservableSource , and then emitting the items emitted by the most recently emitted
of these ObservableSource s.
|
(package private) <R> Flowable<R> |
Flowable.switchMap0(Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
int bufferSize,
boolean delayError) |
|
@NonNull Completable |
Flowable.switchMapCompletable(@NonNull Function<? super @NonNull 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.
|
@NonNull Completable |
Observable.switchMapCompletable(@NonNull Function<? super @NonNull T,? extends CompletableSource> mapper) |
Maps the items of the current Observable into CompletableSource s, subscribes to the newer one while
disposing the subscription to the previous CompletableSource , thus keeping at most one
active CompletableSource running.
|
@NonNull Completable |
Flowable.switchMapCompletableDelayError(@NonNull Function<? super @NonNull 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.
|
@NonNull Completable |
Observable.switchMapCompletableDelayError(@NonNull Function<? super @NonNull 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.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.switchMapDelayError(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper) |
Returns a new Flowable by applying a function that you supply to each item emitted by the current
Flowable that returns a Publisher , and then emitting the items emitted by the most recently emitted
of these Publisher s and delays any error until all Publisher s terminate.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.switchMapDelayError(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper,
int bufferSize) |
Returns a new Flowable by applying a function that you supply to each item emitted by the current
Flowable that returns a Publisher , and then emitting the items emitted by the most recently emitted
of these Publisher s and delays any error until all Publisher s terminate.
|
<@NonNull R> @NonNull Observable<R> |
Observable.switchMapDelayError(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull R>> mapper) |
Returns a new Observable by applying a function that you supply to each item emitted by the current
Observable that returns an ObservableSource , and then emitting the items emitted by the most recently emitted
of these ObservableSource s and delays any error until all ObservableSource s terminate.
|
<@NonNull R> @NonNull Observable<R> |
Observable.switchMapDelayError(@NonNull Function<? super @NonNull T,? extends ObservableSource<? extends @NonNull R>> mapper,
int bufferSize) |
Returns a new Observable by applying a function that you supply to each item emitted by the current
Observable that returns an ObservableSource , and then emitting the items emitted by the most recently emitted
of these ObservableSource s and delays any error until all ObservableSource s terminate.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.switchMapMaybe(@NonNull Function<? super @NonNull T,? extends MaybeSource<? extends @NonNull 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.
|
<@NonNull R> @NonNull Observable<R> |
Observable.switchMapMaybe(@NonNull Function<? super @NonNull T,? extends MaybeSource<? extends @NonNull R>> mapper) |
Maps the items of the current Observable 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 the current Observable or any of the
active inner MaybeSource s fail.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.switchMapMaybeDelayError(@NonNull Function<? super @NonNull T,? extends MaybeSource<? extends @NonNull 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.
|
<@NonNull R> @NonNull Observable<R> |
Observable.switchMapMaybeDelayError(@NonNull Function<? super @NonNull T,? extends MaybeSource<? extends @NonNull 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 the current Observable or the inner MaybeSource s until all terminate.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.switchMapSingle(@NonNull Function<? super @NonNull T,? extends SingleSource<? extends @NonNull 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.
|
<@NonNull R> @NonNull Observable<R> |
Observable.switchMapSingle(@NonNull Function<? super @NonNull T,? extends SingleSource<? extends @NonNull R>> mapper) |
Returns a new Observable by applying a function that you supply to each item emitted by the current
Observable that returns a SingleSource , and then emitting the item emitted by the most recently emitted
of these SingleSource s.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.switchMapSingleDelayError(@NonNull Function<? super @NonNull T,? extends SingleSource<? extends @NonNull 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.
|
<@NonNull R> @NonNull Observable<R> |
Observable.switchMapSingleDelayError(@NonNull Function<? super @NonNull T,? extends SingleSource<? extends @NonNull R>> mapper) |
Returns a new Observable by applying a function that you supply to each item emitted by the current
Observable that returns a SingleSource , and then emitting the item emitted by the most recently emitted
of these SingleSource s and delays any error until all SingleSource s terminate.
|
<@NonNull V> @NonNull Flowable<T> |
Flowable.timeout(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<@NonNull V>> itemTimeoutIndicator) |
Returns a Flowable that mirrors the current Flowable , but notifies Subscriber s of a
TimeoutException if an item emitted by the current Flowable 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.
|
<@NonNull V> @NonNull Flowable<T> |
Flowable.timeout(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<@NonNull V>> itemTimeoutIndicator,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T> fallback) |
Returns a Flowable that mirrors the current Flowable , but that switches to a fallback Publisher if
an item emitted by the current Flowable 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.
|
<@NonNull U,@NonNull V> @NonNull Flowable<T> |
Flowable.timeout(@NonNull org.reactivestreams.Publisher<@NonNull U> firstTimeoutIndicator,
@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<@NonNull V>> itemTimeoutIndicator) |
Returns a Flowable that mirrors the current Flowable , but notifies Subscriber s of a
TimeoutException if either the first item emitted by the current Flowable or any subsequent item
doesn't arrive within time windows defined by other Publisher s.
|
<@NonNull U,@NonNull V> @NonNull Flowable<T> |
Flowable.timeout(@NonNull org.reactivestreams.Publisher<@NonNull U> firstTimeoutIndicator,
@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<@NonNull V>> itemTimeoutIndicator,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T> fallback) |
Returns a Flowable that mirrors the current Flowable , but switches to a fallback Publisher if either
the first item emitted by the current Flowable or any subsequent item doesn't arrive within time windows
defined by other Publisher s.
|
<@NonNull U,@NonNull V> @NonNull Observable<T> |
Observable.timeout(@NonNull ObservableSource<@NonNull U> firstTimeoutIndicator,
@NonNull Function<? super @NonNull T,? extends ObservableSource<@NonNull V>> itemTimeoutIndicator) |
Returns an Observable that mirrors the current Observable , but notifies observers of a
TimeoutException if either the first item emitted by the current Observable or any subsequent item
doesn't arrive within time windows defined by indicator ObservableSource s.
|
<@NonNull U,@NonNull V> @NonNull Observable<T> |
Observable.timeout(@NonNull ObservableSource<@NonNull U> firstTimeoutIndicator,
@NonNull Function<? super @NonNull T,? extends ObservableSource<@NonNull V>> itemTimeoutIndicator,
@NonNull ObservableSource<? extends @NonNull T> fallback) |
Returns an Observable that mirrors the current Observable , but switches to a fallback ObservableSource if either
the first item emitted by the current Observable or any subsequent item doesn't arrive within time windows
defined by indicator ObservableSource s.
|
<@NonNull V> @NonNull Observable<T> |
Observable.timeout(@NonNull Function<? super @NonNull T,? extends ObservableSource<@NonNull V>> itemTimeoutIndicator) |
Returns an Observable that mirrors the current Observable , but notifies observers of a
TimeoutException if an item emitted by the current Observable doesn't arrive within a window of
time after the emission of the previous item, where that period of time is measured by an ObservableSource that
is a function of the previous item.
|
<@NonNull V> @NonNull Observable<T> |
Observable.timeout(@NonNull Function<? super @NonNull T,? extends ObservableSource<@NonNull V>> itemTimeoutIndicator,
@NonNull ObservableSource<? extends @NonNull T> fallback) |
Returns an Observable that mirrors the current Observable , but that switches to a fallback ObservableSource if
an item emitted by the current Observable doesn't arrive within a window of time after the emission of the
previous item, where that period of time is measured by an ObservableSource that is a function of the previous
item.
|
private <@NonNull U,@NonNull V> Flowable<T> |
Flowable.timeout0(org.reactivestreams.Publisher<@NonNull U> firstTimeoutIndicator,
Function<? super @NonNull T,? extends org.reactivestreams.Publisher<@NonNull V>> itemTimeoutIndicator,
org.reactivestreams.Publisher<? extends @NonNull T> fallback) |
|
private <U,V> @NonNull Observable<T> |
Observable.timeout0(@NonNull ObservableSource<U> firstTimeoutIndicator,
@NonNull Function<? super @NonNull T,? extends ObservableSource<V>> itemTimeoutIndicator,
@Nullable ObservableSource<? extends @NonNull T> fallback) |
|
<@NonNull K> @NonNull Single<java.util.Map<K,T>> |
Flowable.toMap(@NonNull Function<? super @NonNull T,? extends @NonNull 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.
|
<@NonNull K,@NonNull V> @NonNull Single<java.util.Map<K,V>> |
Flowable.toMap(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector,
@NonNull Function<? super @NonNull T,? extends @NonNull 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.
|
<@NonNull K,@NonNull V> @NonNull Single<java.util.Map<K,V>> |
Flowable.toMap(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector,
@NonNull Function<? super @NonNull T,? extends @NonNull V> valueSelector,
@NonNull Supplier<? extends java.util.Map<@NonNull K,@NonNull 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 .
|
<@NonNull K> @NonNull Single<@NonNull java.util.Map<K,T>> |
Observable.toMap(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector) |
Returns a Single that emits a single HashMap containing all items emitted by the
current and finite Observable , mapped by the keys returned by a specified
keySelector function.
|
<@NonNull K,@NonNull V> @NonNull Single<java.util.Map<K,V>> |
Observable.toMap(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector,
@NonNull Function<? super @NonNull T,? extends @NonNull V> valueSelector) |
Returns a Single that emits a single HashMap containing values corresponding to items emitted by the
current and finite Observable , mapped by the keys and values returned by the given selector functions.
|
<@NonNull K,@NonNull V> @NonNull Single<java.util.Map<K,V>> |
Observable.toMap(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector,
@NonNull Function<? super @NonNull T,? extends @NonNull V> valueSelector,
@NonNull Supplier<? extends java.util.Map<@NonNull K,@NonNull V>> mapSupplier) |
Returns a Single that emits a single Map (subclass), returned by a specified mapFactory function, that
contains keys and values extracted from the items, via selector functions, emitted by the current and finite Observable .
|
<@NonNull K> @NonNull Single<java.util.Map<K,java.util.Collection<T>>> |
Flowable.toMultimap(@NonNull Function<? super @NonNull T,? extends @NonNull 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.
|
<@NonNull K,@NonNull V> @NonNull Single<java.util.Map<K,java.util.Collection<V>>> |
Flowable.toMultimap(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector,
@NonNull Function<? super @NonNull T,? extends @NonNull 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.
|
<@NonNull K,@NonNull V> @NonNull Single<java.util.Map<K,java.util.Collection<V>>> |
Flowable.toMultimap(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector,
@NonNull Function<? super @NonNull T,? extends @NonNull V> valueSelector,
@NonNull Supplier<? extends java.util.Map<@NonNull K,java.util.Collection<@NonNull V>>> mapSupplier,
@NonNull Function<? super @NonNull K,? extends java.util.Collection<? super @NonNull 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.
|
<@NonNull K,@NonNull V> @NonNull Single<java.util.Map<K,java.util.Collection<V>>> |
Flowable.toMultimap(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector,
@NonNull Function<? super @NonNull T,? extends @NonNull V> valueSelector,
@NonNull Supplier<java.util.Map<@NonNull K,java.util.Collection<@NonNull 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.
|
<@NonNull K> @NonNull Single<@NonNull java.util.Map<K,java.util.Collection<T>>> |
Observable.toMultimap(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector) |
Returns a Single that emits a single HashMap that contains an ArrayList of items emitted by the
current and finite Observable keyed by a specified keySelector function.
|
<@NonNull K,@NonNull V> @NonNull Single<@NonNull java.util.Map<K,java.util.Collection<V>>> |
Observable.toMultimap(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector,
@NonNull Function<? super @NonNull T,? extends @NonNull V> valueSelector,
@NonNull Supplier<? extends java.util.Map<@NonNull K,java.util.Collection<@NonNull V>>> mapSupplier,
@NonNull Function<? super @NonNull K,? extends java.util.Collection<? super @NonNull V>> collectionFactory) |
Returns a Single that emits a single Map (subclass), returned by a specified mapFactory function, that
contains a custom Collection of values, extracted by a specified valueSelector function from
items emitted by the current and finite Observable , and keyed by the keySelector function.
|
<@NonNull K,@NonNull V> @NonNull Single<@NonNull java.util.Map<K,java.util.Collection<V>>> |
Observable.toMultimap(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector,
@NonNull Function<? super @NonNull T,? extends @NonNull V> valueSelector,
@NonNull Supplier<java.util.Map<@NonNull K,java.util.Collection<@NonNull V>>> mapSupplier) |
Returns a Single that emits a single Map (subclass), returned by a specified mapFactory function, that
contains an ArrayList of values, extracted by a specified valueSelector function from items
emitted by the current and finite Observable and keyed by the keySelector function.
|
<@NonNull K,@NonNull V> @NonNull Single<@NonNull java.util.Map<K,java.util.Collection<V>>> |
Observable.toMultimap(@NonNull Function<? super @NonNull T,? extends @NonNull K> keySelector,
Function<? super @NonNull T,? extends @NonNull 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 current and finite Observable ,
keyed by a specified keySelector function.
|
static <@NonNull R> @NonNull Completable |
Completable.using(@NonNull Supplier<@NonNull R> resourceSupplier,
@NonNull Function<? super @NonNull R,? extends CompletableSource> sourceSupplier,
@NonNull Consumer<? super @NonNull R> resourceCleanup) |
Returns a Completable instance which manages a resource along
with a custom CompletableSource instance while the subscription is active.
|
static <@NonNull R> @NonNull Completable |
Completable.using(@NonNull Supplier<@NonNull R> resourceSupplier,
@NonNull Function<? super @NonNull R,? extends CompletableSource> sourceSupplier,
@NonNull Consumer<? super @NonNull R> resourceCleanup,
boolean eager) |
Returns a Completable instance which manages a resource along
with a custom CompletableSource instance while the subscription is active and performs eager or lazy
resource disposition.
|
static <@NonNull T,@NonNull D> @NonNull Flowable<T> |
Flowable.using(@NonNull Supplier<? extends @NonNull D> resourceSupplier,
@NonNull Function<? super @NonNull D,? extends org.reactivestreams.Publisher<? extends @NonNull T>> sourceSupplier,
@NonNull Consumer<? super @NonNull D> resourceCleanup) |
Constructs a Flowable that creates a dependent resource object, a Publisher with
that resource and calls the provided resourceDisposer function if this inner source terminates or the
downstream cancels the flow.
|
static <@NonNull T,@NonNull D> @NonNull Flowable<T> |
Flowable.using(@NonNull Supplier<? extends @NonNull D> resourceSupplier,
@NonNull Function<? super @NonNull D,? extends org.reactivestreams.Publisher<? extends @NonNull T>> sourceSupplier,
@NonNull Consumer<? super @NonNull D> resourceCleanup,
boolean eager) |
Constructs a Flowable that creates a dependent resource object, a Publisher with
that resource and calls the provided resourceDisposer function if this inner source terminates or the
downstream disposes the flow; doing it before these end-states have been reached if eager == true , after otherwise.
|
static <@NonNull T,@NonNull D> @NonNull Maybe<T> |
Maybe.using(@NonNull Supplier<? extends @NonNull D> resourceSupplier,
@NonNull Function<? super @NonNull D,? extends MaybeSource<? extends @NonNull T>> sourceSupplier,
@NonNull Consumer<? super @NonNull D> resourceCleanup) |
Constructs a Maybe that creates a dependent resource object which is disposed of when the
generated MaybeSource terminates or the downstream calls dispose().
|
static <@NonNull T,@NonNull D> @NonNull Maybe<T> |
Maybe.using(@NonNull Supplier<? extends @NonNull D> resourceSupplier,
@NonNull Function<? super @NonNull D,? extends MaybeSource<? extends @NonNull T>> sourceSupplier,
@NonNull Consumer<? super @NonNull D> resourceCleanup,
boolean eager) |
Constructs a Maybe that creates a dependent resource object which is disposed first ({code eager == true})
when the generated MaybeSource terminates or the downstream disposes; or after ({code eager == false}).
|
static <@NonNull T,@NonNull D> @NonNull Observable<T> |
Observable.using(@NonNull Supplier<? extends @NonNull D> resourceSupplier,
@NonNull Function<? super @NonNull D,? extends ObservableSource<? extends @NonNull T>> sourceSupplier,
@NonNull Consumer<? super @NonNull D> resourceCleanup) |
Constructs an Observable that creates a dependent resource object, an ObservableSource with
that resource and calls the provided resourceDisposer function if this inner source terminates or the
downstream disposes the flow.
|
static <@NonNull T,@NonNull D> @NonNull Observable<T> |
Observable.using(@NonNull Supplier<? extends @NonNull D> resourceSupplier,
@NonNull Function<? super @NonNull D,? extends ObservableSource<? extends @NonNull T>> sourceSupplier,
@NonNull Consumer<? super @NonNull D> resourceCleanup,
boolean eager) |
Constructs an Observable that creates a dependent resource object, an ObservableSource with
that resource and calls the provided disposer function if this inner source terminates or the
downstream disposes the flow; doing it before these end-states have been reached if eager == true , after otherwise.
|
static <@NonNull T,@NonNull U> @NonNull Single<T> |
Single.using(@NonNull Supplier<@NonNull U> resourceSupplier,
@NonNull Function<? super @NonNull U,? extends SingleSource<? extends @NonNull T>> sourceSupplier,
@NonNull Consumer<? super @NonNull U> resourceCleanup) |
Allows using and disposing a resource while running a SingleSource instance generated from
that resource (similar to a try-with-resources).
|
static <@NonNull T,@NonNull U> @NonNull Single<T> |
Single.using(@NonNull Supplier<@NonNull U> resourceSupplier,
@NonNull Function<? super @NonNull U,? extends SingleSource<? extends @NonNull T>> sourceSupplier,
@NonNull Consumer<? super @NonNull U> resourceCleanup,
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> S |
Scheduler.when(@NonNull Function<Flowable<Flowable<Completable>>,Completable> combine) |
Allows the use of operators for controlling the timing around when
actions scheduled on workers are actually done.
|
<@NonNull U,@NonNull V> @NonNull Flowable<Flowable<T>> |
Flowable.window(@NonNull org.reactivestreams.Publisher<@NonNull U> openingIndicator,
@NonNull Function<? super @NonNull U,? extends org.reactivestreams.Publisher<@NonNull V>> closingIndicator) |
Returns a Flowable that emits windows of items it collects from the current Flowable .
|
<@NonNull U,@NonNull V> @NonNull Flowable<Flowable<T>> |
Flowable.window(@NonNull org.reactivestreams.Publisher<@NonNull U> openingIndicator,
@NonNull Function<? super @NonNull U,? extends org.reactivestreams.Publisher<@NonNull V>> closingIndicator,
int bufferSize) |
Returns a Flowable that emits windows of items it collects from the current Flowable .
|
<@NonNull U,@NonNull V> @NonNull Observable<Observable<T>> |
Observable.window(@NonNull ObservableSource<@NonNull U> openingIndicator,
@NonNull Function<? super @NonNull U,? extends ObservableSource<@NonNull V>> closingIndicator) |
Returns an Observable that emits windows of items it collects from the current Observable .
|
<@NonNull U,@NonNull V> @NonNull Observable<Observable<T>> |
Observable.window(@NonNull ObservableSource<@NonNull U> openingIndicator,
@NonNull Function<? super @NonNull U,? extends ObservableSource<@NonNull V>> closingIndicator,
int bufferSize) |
Returns an Observable that emits windows of items it collects from the current Observable .
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.withLatestFrom(@NonNull java.lang.Iterable<? extends org.reactivestreams.Publisher<?>> others,
@NonNull Function<? super java.lang.Object[],@NonNull R> combiner) |
Combines the value emission from the current Flowable with the latest emissions from the
other Publisher s via a function to produce the output item.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.withLatestFrom(@NonNull org.reactivestreams.Publisher<?>[] others,
@NonNull Function<? super java.lang.Object[],@NonNull R> combiner) |
Combines the value emission from the current Flowable with the latest emissions from the
other Publisher s via a function to produce the output item.
|
<@NonNull R> @NonNull Observable<R> |
Observable.withLatestFrom(@NonNull ObservableSource<?>[] others,
@NonNull Function<? super java.lang.Object[],@NonNull R> combiner) |
Combines the value emission from the current Observable with the latest emissions from the
other ObservableSource s via a function to produce the output item.
|
<@NonNull R> @NonNull Observable<R> |
Observable.withLatestFrom(@NonNull java.lang.Iterable<? extends ObservableSource<?>> others,
@NonNull Function<? super java.lang.Object[],@NonNull R> combiner) |
Combines the value emission from the current Observable with the latest emissions from the
other ObservableSource s via a function to produce the output item.
|
static <@NonNull T,@NonNull R> @NonNull Flowable<R> |
Flowable.zip(@NonNull java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources,
@NonNull Function<? super java.lang.Object[],? extends @NonNull 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 Publisher s.
|
static <@NonNull T,@NonNull R> @NonNull Flowable<R> |
Flowable.zip(@NonNull java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources,
@NonNull Function<? super java.lang.Object[],? extends @NonNull 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 Publisher s.
|
static <@NonNull T,@NonNull R> @NonNull Maybe<R> |
Maybe.zip(@NonNull java.lang.Iterable<? extends MaybeSource<? extends @NonNull T>> sources,
@NonNull Function<? super java.lang.Object[],? extends @NonNull 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 MaybeSource s.
|
static <@NonNull T,@NonNull R> @NonNull Observable<R> |
Observable.zip(@NonNull java.lang.Iterable<? extends ObservableSource<? extends @NonNull T>> sources,
@NonNull Function<? super java.lang.Object[],? extends @NonNull 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 ObservableSource s.
|
static <@NonNull T,@NonNull R> @NonNull Observable<R> |
Observable.zip(@NonNull java.lang.Iterable<? extends ObservableSource<? extends @NonNull T>> sources,
@NonNull Function<? super java.lang.Object[],? extends @NonNull 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 ObservableSource s.
|
static <@NonNull T,@NonNull R> @NonNull Single<R> |
Single.zip(@NonNull java.lang.Iterable<? extends SingleSource<? extends @NonNull T>> sources,
@NonNull Function<? super java.lang.Object[],? extends @NonNull 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 the downstream.
|
static <@NonNull T,@NonNull R> @NonNull Flowable<R> |
Flowable.zipArray(@NonNull Function<? super java.lang.Object[],? extends @NonNull R> zipper,
boolean delayError,
int bufferSize,
@NonNull org.reactivestreams.Publisher<? extends @NonNull 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 Publisher s.
|
static <@NonNull T,@NonNull R> @NonNull Maybe<R> |
Maybe.zipArray(@NonNull Function<? super java.lang.Object[],? extends @NonNull R> zipper,
@NonNull MaybeSource<? extends @NonNull 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 MaybeSource s.
|
static <@NonNull T,@NonNull R> @NonNull Observable<R> |
Observable.zipArray(@NonNull Function<? super java.lang.Object[],? extends @NonNull R> zipper,
boolean delayError,
int bufferSize,
@NonNull ObservableSource<? extends @NonNull 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 ObservableSource s.
|
static <@NonNull T,@NonNull R> @NonNull Single<R> |
Single.zipArray(@NonNull Function<? super java.lang.Object[],? extends @NonNull R> zipper,
@NonNull SingleSource<? extends @NonNull 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.
|