static <@NonNull T> @NonNull Flowable<T> |
Flowable.amb(@NonNull java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources) |
Mirrors the one Publisher in an Iterable of several Publisher s that first either emits an item or sends
a termination notification.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.ambArray(@NonNull org.reactivestreams.Publisher<? extends @NonNull T>... sources) |
Mirrors the one Publisher in an array of several Publisher s that first either emits an item or sends
a termination notification.
|
@NonNull Flowable<T> |
Flowable.ambWith(@NonNull org.reactivestreams.Publisher<? extends @NonNull T> other) |
Mirrors the Publisher (current or provided) that first either emits an item or sends a termination
notification.
|
<@NonNull T> @NonNull Flowable<T> |
Completable.andThen(@NonNull org.reactivestreams.Publisher<@NonNull T> next) |
Returns a Flowable which will subscribe to this Completable and once that is completed then
will subscribe to the next Publisher .
|
@NonNull Flowable<java.util.List<T>> |
Flowable.buffer(int count) |
Returns a Flowable that emits buffers of items it collects from the current Flowable .
|
@NonNull Flowable<java.util.List<T>> |
Flowable.buffer(int count,
int skip) |
Returns a Flowable that emits buffers of items it collects from the current Flowable .
|
<@NonNull U extends java.util.Collection<? super @NonNull T>> @NonNull Flowable<U> |
Flowable.buffer(int count,
int skip,
@NonNull Supplier<@NonNull U> bufferSupplier) |
Returns a Flowable that emits buffers of items it collects from the current Flowable .
|
<@NonNull U extends java.util.Collection<? super @NonNull T>> @NonNull Flowable<U> |
Flowable.buffer(int count,
@NonNull Supplier<@NonNull U> bufferSupplier) |
Returns a Flowable that emits buffers of items it collects from the current Flowable .
|
@NonNull Flowable<java.util.List<T>> |
Flowable.buffer(long timespan,
long timeskip,
@NonNull java.util.concurrent.TimeUnit unit) |
Returns a Flowable that emits buffers of items it collects from the current Flowable .
|
@NonNull Flowable<java.util.List<T>> |
Flowable.buffer(long timespan,
long timeskip,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler) |
Returns a Flowable that emits buffers of items it collects from the current Flowable .
|
<@NonNull U extends java.util.Collection<? super @NonNull T>> @NonNull Flowable<U> |
Flowable.buffer(long timespan,
long timeskip,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
@NonNull Supplier<@NonNull U> bufferSupplier) |
Returns a Flowable that emits buffers of items it collects from the current Flowable .
|
@NonNull Flowable<java.util.List<T>> |
Flowable.buffer(long timespan,
@NonNull java.util.concurrent.TimeUnit unit) |
Returns a Flowable that emits buffers of items it collects from the current Flowable .
|
@NonNull Flowable<java.util.List<T>> |
Flowable.buffer(long timespan,
@NonNull java.util.concurrent.TimeUnit unit,
int count) |
Returns a Flowable that emits buffers of items it collects from the current Flowable .
|
@NonNull Flowable<java.util.List<T>> |
Flowable.buffer(long timespan,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler) |
Returns a Flowable that emits buffers of items it collects from the current Flowable .
|
@NonNull Flowable<java.util.List<T>> |
Flowable.buffer(long timespan,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
int count) |
Returns a Flowable that emits buffers of items it collects from the current Flowable .
|
<@NonNull U extends java.util.Collection<? super @NonNull T>> @NonNull Flowable<U> |
Flowable.buffer(long timespan,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
int count,
@NonNull Supplier<@NonNull U> bufferSupplier,
boolean restartTimerOnMaxSize) |
Returns a Flowable that emits buffers of items it collects from the current Flowable .
|
<@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 B> @NonNull Flowable<java.util.List<T>> |
Flowable.buffer(@NonNull org.reactivestreams.Publisher<@NonNull B> boundaryIndicator) |
Returns a Flowable that emits non-overlapping buffered items from the current Flowable each time the
specified boundary Publisher emits an item.
|
<@NonNull B> @NonNull Flowable<java.util.List<T>> |
Flowable.buffer(@NonNull org.reactivestreams.Publisher<@NonNull B> boundaryIndicator,
int initialCapacity) |
Returns a Flowable that emits non-overlapping buffered items from the current Flowable each time the
specified boundary Publisher emits an item.
|
<@NonNull B,@NonNull U extends java.util.Collection<? super @NonNull T>> @NonNull Flowable<U> |
Flowable.buffer(@NonNull org.reactivestreams.Publisher<@NonNull B> boundaryIndicator,
@NonNull Supplier<@NonNull U> bufferSupplier) |
Returns a Flowable that emits non-overlapping buffered items from the current Flowable each time the
specified boundary Publisher emits an item.
|
@NonNull Flowable<T> |
Flowable.cache() |
Returns a Flowable that subscribes to this Publisher lazily, caches all of its events
and replays them, in the same order as received, to all the downstream subscribers.
|
@NonNull Flowable<T> |
Flowable.cacheWithInitialCapacity(int initialCapacity) |
Returns a Flowable that subscribes to this Publisher lazily, caches all of its events
and replays them, in the same order as received, to all the downstream subscribers.
|
<@NonNull U> @NonNull Flowable<U> |
Flowable.cast(@NonNull java.lang.Class<@NonNull U> clazz) |
Returns a Flowable that emits the upstream items while
they can be cast via Class.cast(Object) until the upstream terminates,
or until the upstream signals an item which can't be cast,
resulting in a ClassCastException to be signaled to the downstream.
|
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 T1,@NonNull T2,@NonNull R> @NonNull Flowable<R> |
Flowable.combineLatest(@NonNull org.reactivestreams.Publisher<? extends @NonNull T1> source1,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T2> source2,
@NonNull BiFunction<? super @NonNull T1,? super @NonNull T2,? extends @NonNull R> combiner) |
Combines two 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 either of the source Publisher s, where this
aggregation is defined by a specified function.
|
static <@NonNull T1,@NonNull T2,@NonNull T3,@NonNull R> @NonNull Flowable<R> |
Flowable.combineLatest(@NonNull org.reactivestreams.Publisher<? extends @NonNull T1> source1,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T2> source2,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T3> source3,
@NonNull Function3<? super @NonNull T1,? super @NonNull T2,? super @NonNull T3,? extends @NonNull R> combiner) |
Combines three 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 T1,@NonNull T2,@NonNull T3,@NonNull T4,@NonNull R> @NonNull Flowable<R> |
Flowable.combineLatest(@NonNull org.reactivestreams.Publisher<? extends @NonNull T1> source1,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T2> source2,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T3> source3,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T4> source4,
@NonNull Function4<? super @NonNull T1,? super @NonNull T2,? super @NonNull T3,? super @NonNull T4,? extends @NonNull R> combiner) |
Combines four 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 T1,@NonNull T2,@NonNull T3,@NonNull T4,@NonNull T5,@NonNull R> @NonNull Flowable<R> |
Flowable.combineLatest(@NonNull org.reactivestreams.Publisher<? extends @NonNull T1> source1,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T2> source2,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T3> source3,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T4> source4,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T5> source5,
@NonNull Function5<? super @NonNull T1,? super @NonNull T2,? super @NonNull T3,? super @NonNull T4,? super @NonNull T5,? extends @NonNull R> combiner) |
Combines five 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 T1,@NonNull T2,@NonNull T3,@NonNull T4,@NonNull T5,@NonNull T6,@NonNull R> @NonNull Flowable<R> |
Flowable.combineLatest(@NonNull org.reactivestreams.Publisher<? extends @NonNull T1> source1,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T2> source2,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T3> source3,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T4> source4,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T5> source5,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T6> source6,
@NonNull Function6<? super @NonNull T1,? super @NonNull T2,? super @NonNull T3,? super @NonNull T4,? super @NonNull T5,? super @NonNull T6,? extends @NonNull R> combiner) |
Combines six 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 T1,@NonNull T2,@NonNull T3,@NonNull T4,@NonNull T5,@NonNull T6,@NonNull T7,@NonNull R> @NonNull Flowable<R> |
Flowable.combineLatest(@NonNull org.reactivestreams.Publisher<? extends @NonNull T1> source1,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T2> source2,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T3> source3,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T4> source4,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T5> source5,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T6> source6,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T7> source7,
@NonNull Function7<? super @NonNull T1,? super @NonNull T2,? super @NonNull T3,? super @NonNull T4,? super @NonNull T5,? super @NonNull T6,? super @NonNull T7,? extends @NonNull R> combiner) |
Combines seven 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 T1,@NonNull T2,@NonNull T3,@NonNull T4,@NonNull T5,@NonNull T6,@NonNull T7,@NonNull T8,@NonNull R> @NonNull Flowable<R> |
Flowable.combineLatest(@NonNull org.reactivestreams.Publisher<? extends @NonNull T1> source1,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T2> source2,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T3> source3,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T4> source4,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T5> source5,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T6> source6,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T7> source7,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T8> source8,
@NonNull Function8<? super @NonNull T1,? super @NonNull T2,? super @NonNull T3,? super @NonNull T4,? super @NonNull T5,? super @NonNull T6,? super @NonNull T7,? super @NonNull T8,? extends @NonNull R> combiner) |
Combines eight 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 T1,@NonNull T2,@NonNull T3,@NonNull T4,@NonNull T5,@NonNull T6,@NonNull T7,@NonNull T8,@NonNull T9,@NonNull R> @NonNull Flowable<R> |
Flowable.combineLatest(@NonNull org.reactivestreams.Publisher<? extends @NonNull T1> source1,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T2> source2,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T3> source3,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T4> source4,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T5> source5,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T6> source6,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T7> source7,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T8> source8,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T9> source9,
@NonNull Function9<? super @NonNull T1,? super @NonNull T2,? super @NonNull T3,? super @NonNull T4,? super @NonNull T5,? super @NonNull T6,? super @NonNull T7,? super @NonNull T8,? super @NonNull T9,? extends @NonNull R> combiner) |
Combines nine 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) |
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 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 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.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.compose(@NonNull FlowableTransformer<? super @NonNull T,? extends @NonNull R> composer) |
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.concat(@NonNull java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources) |
Concatenates elements of each Publisher provided via an Iterable sequence into a single sequence
of elements without interleaving them.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.concat(@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source1,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source2) |
Returns a Flowable that emits the items emitted by two Publisher s, one after the other, without
interleaving them.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.concat(@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source1,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source2,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source3) |
Returns a Flowable that emits the items emitted by three Publisher s, one after the other, without
interleaving them.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.concat(@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source1,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source2,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source3,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source4) |
Returns a Flowable that emits the items emitted by four Publisher s, one after the other, without
interleaving them.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.concat(@NonNull org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources) |
Returns a Flowable that emits the items emitted by each of the Publisher s emitted by the source
Publisher , one after the other, without interleaving them.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.concat(@NonNull org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources,
int prefetch) |
Returns a Flowable that emits the items emitted by each of the Publisher s emitted by the source
Publisher , one after the other, without interleaving them.
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.concat(@NonNull MaybeSource<? extends @NonNull T> source1,
@NonNull MaybeSource<? extends @NonNull T> source2) |
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.concat(@NonNull MaybeSource<? extends @NonNull T> source1,
@NonNull MaybeSource<? extends @NonNull T> source2,
@NonNull MaybeSource<? extends @NonNull T> source3) |
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.concat(@NonNull MaybeSource<? extends @NonNull T> source1,
@NonNull MaybeSource<? extends @NonNull T> source2,
@NonNull MaybeSource<? extends @NonNull T> source3,
@NonNull MaybeSource<? extends @NonNull T> source4) |
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.concat(@NonNull java.lang.Iterable<? extends MaybeSource<? extends @NonNull T>> sources) |
Concatenate the single values, in a non-overlapping fashion, of the MaybeSource sources provided by
an Iterable sequence as a Flowable sequence.
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.concat(@NonNull org.reactivestreams.Publisher<? extends MaybeSource<? extends @NonNull T>> sources) |
Concatenate the single values, in a non-overlapping fashion, of the MaybeSource sources provided by
a Publisher sequence as a Flowable sequence.
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.concat(@NonNull org.reactivestreams.Publisher<? extends MaybeSource<? extends @NonNull T>> sources,
int prefetch) |
Concatenate the single values, in a non-overlapping fashion, of the MaybeSource sources provided by
a Publisher sequence as a Flowable sequence.
|
static <@NonNull T> @NonNull Flowable<T> |
Single.concat(@NonNull SingleSource<? extends @NonNull T> source1,
@NonNull SingleSource<? extends @NonNull T> source2) |
|
static <@NonNull T> @NonNull Flowable<T> |
Single.concat(@NonNull SingleSource<? extends @NonNull T> source1,
@NonNull SingleSource<? extends @NonNull T> source2,
@NonNull SingleSource<? extends @NonNull T> source3) |
|
static <@NonNull T> @NonNull Flowable<T> |
Single.concat(@NonNull SingleSource<? extends @NonNull T> source1,
@NonNull SingleSource<? extends @NonNull T> source2,
@NonNull SingleSource<? extends @NonNull T> source3,
@NonNull SingleSource<? extends @NonNull T> source4) |
|
static <@NonNull T> @NonNull Flowable<T> |
Single.concat(@NonNull java.lang.Iterable<? extends SingleSource<? extends @NonNull T>> sources) |
Concatenate the single values, in a non-overlapping fashion, of the SingleSource s provided by
an Iterable sequence.
|
static <@NonNull T> @NonNull Flowable<T> |
Single.concat(@NonNull org.reactivestreams.Publisher<? extends SingleSource<? extends @NonNull T>> sources) |
Concatenate the single values, in a non-overlapping fashion, of the SingleSource s provided by
a Publisher sequence.
|
static <@NonNull T> @NonNull Flowable<T> |
Single.concat(@NonNull org.reactivestreams.Publisher<? extends SingleSource<? extends @NonNull T>> sources,
int prefetch) |
Concatenate the single values, in a non-overlapping fashion, of the SingleSource s provided by
a Publisher sequence and prefetched by the specified amount.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.concatArray(@NonNull org.reactivestreams.Publisher<? extends @NonNull T>... sources) |
Concatenates a variable number of Publisher sources.
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.concatArray(@NonNull MaybeSource<? extends @NonNull T>... sources) |
Concatenate the single values, in a non-overlapping fashion, of the MaybeSource sources in the array
as a Flowable sequence.
|
static <@NonNull T> @NonNull Flowable<T> |
Single.concatArray(@NonNull SingleSource<? extends @NonNull T>... sources) |
Concatenate the single values, in a non-overlapping fashion, of the SingleSource s provided in
an array.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.concatArrayDelayError(@NonNull org.reactivestreams.Publisher<? extends @NonNull T>... sources) |
Concatenates a variable number of Publisher sources and delays errors from any of them
till all terminate.
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.concatArrayDelayError(@NonNull MaybeSource<? extends @NonNull T>... sources) |
Concatenates a variable number of MaybeSource sources and delays errors from any of them
till all terminate as a Flowable sequence.
|
static <@NonNull T> @NonNull Flowable<T> |
Single.concatArrayDelayError(@NonNull SingleSource<? extends @NonNull T>... sources) |
Concatenate the single values, in a non-overlapping fashion, of the SingleSource s provided in
an array.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.concatArrayEager(int maxConcurrency,
int prefetch,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T>... sources) |
Concatenates an array of Publisher s eagerly into a single stream of values.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.concatArrayEager(@NonNull org.reactivestreams.Publisher<? extends @NonNull T>... sources) |
Concatenates an array of Publisher s eagerly into a single stream of values.
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.concatArrayEager(@NonNull MaybeSource<? extends @NonNull T>... sources) |
|
static <@NonNull T> @NonNull Flowable<T> |
Single.concatArrayEager(@NonNull SingleSource<? extends @NonNull T>... sources) |
Concatenates a sequence of SingleSource eagerly into a single stream of values.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.concatArrayEagerDelayError(int maxConcurrency,
int prefetch,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T>... sources) |
Concatenates an array of Publisher s eagerly into a single stream of values
and delaying any errors until all sources terminate.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.concatArrayEagerDelayError(@NonNull org.reactivestreams.Publisher<? extends @NonNull T>... sources) |
Concatenates an array of Publisher s eagerly into a single stream of values
and delaying any errors until all sources terminate.
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.concatArrayEagerDelayError(@NonNull MaybeSource<? extends @NonNull T>... sources) |
|
static <@NonNull T> @NonNull Flowable<T> |
Single.concatArrayEagerDelayError(@NonNull SingleSource<? extends @NonNull T>... sources) |
Concatenates a sequence of SingleSource eagerly into a single stream of values.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.concatDelayError(@NonNull java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources) |
Concatenates the Iterable sequence of Publisher s into a single sequence by subscribing to each Publisher ,
one after the other, one at a time and delays any errors till the all inner Publisher s terminate.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.concatDelayError(@NonNull org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources) |
Concatenates the Publisher sequence of Publisher s into a single sequence by subscribing to each inner Publisher ,
one after the other, one at a time and delays any errors till the all inner and the outer Publisher s terminate.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.concatDelayError(@NonNull org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources,
int prefetch,
boolean tillTheEnd) |
Concatenates the Publisher sequence of Publisher s into a single sequence by subscribing to each inner Publisher ,
one after the other, one at a time and delays any errors till the all inner and the outer Publisher s terminate.
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.concatDelayError(@NonNull java.lang.Iterable<? extends MaybeSource<? extends @NonNull T>> sources) |
Concatenates the Iterable sequence of MaybeSource s into a single sequence by subscribing to each MaybeSource ,
one after the other, one at a time and delays any errors till the all inner MaybeSource s terminate
as a Flowable sequence.
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.concatDelayError(@NonNull org.reactivestreams.Publisher<? extends MaybeSource<? extends @NonNull T>> sources) |
Concatenates the Publisher sequence of MaybeSource s into a single sequence by subscribing to each inner MaybeSource ,
one after the other, one at a time and delays any errors till the all inner and the outer Publisher terminate
as a Flowable sequence.
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.concatDelayError(@NonNull org.reactivestreams.Publisher<? extends MaybeSource<? extends @NonNull T>> sources,
int prefetch) |
Concatenates the Publisher sequence of MaybeSource s into a single sequence by subscribing to each inner MaybeSource ,
one after the other, one at a time and delays any errors till the all inner and the outer Publisher terminate
as a Flowable sequence.
|
static <@NonNull T> @NonNull Flowable<T> |
Single.concatDelayError(@NonNull java.lang.Iterable<? extends SingleSource<? extends @NonNull T>> sources) |
Concatenates the Iterable sequence of SingleSource s into a single sequence by subscribing to each SingleSource ,
one after the other, one at a time and delays any errors till the all inner SingleSource s terminate
as a Flowable sequence.
|
static <@NonNull T> @NonNull Flowable<T> |
Single.concatDelayError(@NonNull org.reactivestreams.Publisher<? extends SingleSource<? extends @NonNull T>> sources) |
Concatenates the Publisher sequence of SingleSource s into a single sequence by subscribing to each inner SingleSource ,
one after the other, one at a time and delays any errors till the all inner and the outer Publisher terminate
as a Flowable sequence.
|
static <@NonNull T> @NonNull Flowable<T> |
Single.concatDelayError(@NonNull org.reactivestreams.Publisher<? extends SingleSource<? extends @NonNull T>> sources,
int prefetch) |
Concatenates the Publisher sequence of SingleSource s into a single sequence by subscribing to each inner SingleSource ,
one after the other, one at a time and delays any errors till the all inner and the outer Publisher terminate
as a Flowable sequence.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.concatEager(@NonNull java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources) |
Concatenates a sequence of Publisher s eagerly into a single stream of values.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.concatEager(@NonNull java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources,
int maxConcurrency,
int prefetch) |
Concatenates a sequence of Publisher s eagerly into a single stream of values and
runs a limited number of inner sequences at once.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.concatEager(@NonNull org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources) |
Concatenates a Publisher sequence of Publisher s eagerly into a single stream of values.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.concatEager(@NonNull org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources,
int maxConcurrency,
int prefetch) |
Concatenates a Publisher sequence of Publisher s eagerly into a single stream of values and
runs a limited number of inner sequences at once.
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.concatEager(@NonNull java.lang.Iterable<? extends MaybeSource<? extends @NonNull T>> sources) |
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.concatEager(@NonNull java.lang.Iterable<? extends MaybeSource<? extends @NonNull T>> sources,
int maxConcurrency) |
Concatenates a sequence of MaybeSource s eagerly into a Flowable sequence and
runs a limited number of the inner sequences at once.
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.concatEager(@NonNull org.reactivestreams.Publisher<? extends MaybeSource<? extends @NonNull T>> sources) |
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.concatEager(@NonNull org.reactivestreams.Publisher<? extends MaybeSource<? extends @NonNull T>> sources,
int maxConcurrency) |
Concatenates a Publisher sequence of MaybeSource s eagerly into a Flowable sequence,
running at most the given number of inner MaybeSource s at once.
|
static <@NonNull T> @NonNull Flowable<T> |
Single.concatEager(@NonNull java.lang.Iterable<? extends SingleSource<? extends @NonNull T>> sources) |
Concatenates an Iterable sequence of SingleSource s eagerly into a single stream of values.
|
static <@NonNull T> @NonNull Flowable<T> |
Single.concatEager(@NonNull java.lang.Iterable<? extends SingleSource<? extends @NonNull T>> sources,
int maxConcurrency) |
Concatenates an Iterable sequence of SingleSource s eagerly into a single stream of values and
runs a limited number of the inner sources at once.
|
static <@NonNull T> @NonNull Flowable<T> |
Single.concatEager(@NonNull org.reactivestreams.Publisher<? extends SingleSource<? extends @NonNull T>> sources) |
Concatenates a Publisher sequence of SingleSource s eagerly into a single stream of values.
|
static <@NonNull T> @NonNull Flowable<T> |
Single.concatEager(@NonNull org.reactivestreams.Publisher<? extends SingleSource<? extends @NonNull T>> sources,
int maxConcurrency) |
Concatenates a Publisher sequence of SingleSource s eagerly into a single stream of values and
runs a limited number of those inner SingleSource s at once.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.concatEagerDelayError(@NonNull java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources) |
Concatenates a sequence of Publisher s eagerly into a single stream of values,
delaying errors until all the inner sequences terminate.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.concatEagerDelayError(@NonNull java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources,
int maxConcurrency,
int prefetch) |
Concatenates a sequence of Publisher s eagerly into a single stream of values,
delaying errors until all the inner sequences terminate and runs a limited number
of inner sequences at once.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.concatEagerDelayError(@NonNull org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources) |
Concatenates a Publisher sequence of Publisher s eagerly into a single stream of values,
delaying errors until all the inner and the outer sequences terminate.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.concatEagerDelayError(@NonNull org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources,
int maxConcurrency,
int prefetch) |
Concatenates a Publisher sequence of Publisher s eagerly into a single stream of values,
delaying errors until all the inner and outer sequences terminate and runs a limited number of inner
sequences at once.
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.concatEagerDelayError(@NonNull java.lang.Iterable<? extends MaybeSource<? extends @NonNull T>> sources) |
Concatenates a sequence of MaybeSource s eagerly into a Flowable sequence,
delaying errors until all inner MaybeSource s terminate.
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.concatEagerDelayError(@NonNull java.lang.Iterable<? extends MaybeSource<? extends @NonNull T>> sources,
int maxConcurrency) |
Concatenates a sequence of MaybeSource s eagerly into a Flowable sequence,
delaying errors until all inner MaybeSource s terminate and
runs a limited number of inner MaybeSource s at once.
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.concatEagerDelayError(@NonNull org.reactivestreams.Publisher<? extends MaybeSource<? extends @NonNull T>> sources) |
Concatenates a Publisher sequence of MaybeSource s eagerly into a Flowable sequence,
delaying errors until all the inner and the outer sequence terminate.
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.concatEagerDelayError(@NonNull org.reactivestreams.Publisher<? extends MaybeSource<? extends @NonNull T>> sources,
int maxConcurrency) |
Concatenates a Publisher sequence of MaybeSource s eagerly into a Flowable sequence,
delaying errors until all the inner and the outer sequence terminate and
runs a limited number of the inner MaybeSource s at once.
|
static <@NonNull T> @NonNull Flowable<T> |
Single.concatEagerDelayError(@NonNull java.lang.Iterable<? extends SingleSource<? extends @NonNull T>> sources) |
Concatenates an Iterable sequence of SingleSource s eagerly into a single stream of values,
delaying errors until all the inner sources terminate.
|
static <@NonNull T> @NonNull Flowable<T> |
Single.concatEagerDelayError(@NonNull java.lang.Iterable<? extends SingleSource<? extends @NonNull T>> sources,
int maxConcurrency) |
Concatenates an Iterable sequence of SingleSource s eagerly into a single stream of values,
delaying errors until all the inner sources terminate.
|
static <@NonNull T> @NonNull Flowable<T> |
Single.concatEagerDelayError(@NonNull org.reactivestreams.Publisher<? extends SingleSource<? extends @NonNull T>> sources) |
Concatenates a Publisher sequence of SingleSource s eagerly into a single stream of values,
delaying errors until all the inner and the outer sequence terminate.
|
static <@NonNull T> @NonNull Flowable<T> |
Single.concatEagerDelayError(@NonNull org.reactivestreams.Publisher<? extends SingleSource<? extends @NonNull T>> sources,
int maxConcurrency) |
Concatenates a Publisher sequence of SingleSource s eagerly into a single stream of values,
running at most the specified number of those inner SingleSource s at once and
delaying errors until all the inner and the outer sequence 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 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 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 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 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 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 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 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 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 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 Flowable<T> |
Flowable.concatWith(@NonNull CompletableSource other) |
Returns a Flowable that emits items from this Flowable and when it completes normally, the
other CompletableSource is subscribed to and the returned Flowable emits its terminal events.
|
@NonNull Flowable<T> |
Flowable.concatWith(@NonNull MaybeSource<? extends @NonNull T> other) |
Returns a Flowable that emits the items from this Flowable followed by the success item or terminal events
of the other MaybeSource .
|
@NonNull Flowable<T> |
Flowable.concatWith(@NonNull SingleSource<? extends @NonNull T> other) |
Returns a Flowable that emits the items from this Flowable followed by the success item or error event
of the other SingleSource .
|
@NonNull Flowable<T> |
Flowable.concatWith(@NonNull org.reactivestreams.Publisher<? extends @NonNull T> other) |
Returns a Flowable that emits the items emitted from the current Flowable , then the next, one after
the other, without interleaving them.
|
@NonNull Flowable<T> |
Maybe.concatWith(@NonNull MaybeSource<? extends @NonNull T> other) |
Returns a Flowable that emits the items emitted from the current Maybe , then the other MaybeSource , one after
the other, without interleaving them.
|
@NonNull Flowable<T> |
Single.concatWith(@NonNull SingleSource<? extends @NonNull T> other) |
Returns a Flowable that emits the item emitted by the current Single , then the item emitted by the
specified SingleSource .
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.create(@NonNull FlowableOnSubscribe<@NonNull T> source,
@NonNull BackpressureStrategy mode) |
Provides an API (via a cold Flowable ) that bridges the reactive world with the callback-style,
generally non-backpressured world.
|
@NonNull Flowable<T> |
Flowable.debounce(long timeout,
@NonNull java.util.concurrent.TimeUnit unit) |
Returns a Flowable that mirrors the current Flowable , except that it drops items emitted by the
current Flowable that are followed by newer items before a timeout value expires.
|
@NonNull Flowable<T> |
Flowable.debounce(long timeout,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler) |
Returns a Flowable that mirrors the current Flowable , except that it drops items emitted by the
current Flowable that are followed by newer items before a timeout value expires on a specified
Scheduler .
|
@NonNull Flowable<T> |
Flowable.debounce(long timeout,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
@NonNull Consumer<? super @NonNull T> onDropped) |
Returns a Flowable that mirrors the current Flowable , except that it drops items emitted by the
current Flowable that are followed by newer items before a timeout value expires on a specified
Scheduler .
|
<@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 Flowable<T> |
Flowable.defaultIfEmpty(@NonNull T defaultItem) |
Returns a Flowable that emits the items emitted by the current Flowable or a specified default item
if the current Flowable is empty.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.defer(@NonNull Supplier<? extends @NonNull org.reactivestreams.Publisher<? extends @NonNull T>> supplier) |
Returns a Flowable that calls a Publisher factory to create a Publisher for each new Subscriber
that subscribes.
|
@NonNull Flowable<T> |
Flowable.delay(long time,
@NonNull java.util.concurrent.TimeUnit unit) |
Returns a Flowable that emits the items emitted by the current Flowable shifted forward in time by a
specified delay.
|
@NonNull Flowable<T> |
Flowable.delay(long time,
@NonNull java.util.concurrent.TimeUnit unit,
boolean delayError) |
Returns a Flowable that emits the items emitted by the current Flowable shifted forward in time by a
specified delay.
|
@NonNull Flowable<T> |
Flowable.delay(long time,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler) |
Returns a Flowable that emits the items emitted by the current Flowable shifted forward in time by a
specified delay.
|
@NonNull Flowable<T> |
Flowable.delay(long time,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
boolean delayError) |
Returns a Flowable that emits the items emitted by the current Flowable shifted forward in time by a
specified delay.
|
<@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 Flowable<T> |
Flowable.delaySubscription(long time,
@NonNull java.util.concurrent.TimeUnit unit) |
Returns a Flowable that delays the subscription to the current Flowable by a given amount of time.
|
@NonNull Flowable<T> |
Flowable.delaySubscription(long time,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler) |
Returns a Flowable that delays the subscription to the current Flowable by a given amount of time,
both waiting and subscribing on a given Scheduler .
|
<@NonNull U> @NonNull Flowable<T> |
Flowable.delaySubscription(@NonNull org.reactivestreams.Publisher<@NonNull U> subscriptionIndicator) |
Returns a Flowable that delays the subscription to this Publisher
until the other Publisher emits an element or completes normally.
|
<@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 Flowable<T> |
Flowable.distinct() |
Returns a Flowable that emits all items emitted by the current Flowable that are distinct
based on Object.equals(Object) comparison.
|
<@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 Flowable<T> |
Flowable.distinctUntilChanged() |
Returns a Flowable that emits all items emitted by the current Flowable that are distinct from their
immediate predecessors based on Object.equals(Object) comparison.
|
@NonNull Flowable<T> |
Flowable.distinctUntilChanged(@NonNull BiPredicate<? super @NonNull T,? super @NonNull T> comparer) |
Returns a Flowable that emits all items emitted by the current Flowable that are distinct from their
immediate predecessors when compared with each other via the provided comparator 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 Flowable<T> |
Flowable.doAfterNext(@NonNull Consumer<? super @NonNull T> onAfterNext) |
Calls the specified consumer with the current item after this item has been emitted to the downstream.
|
@NonNull Flowable<T> |
Flowable.doAfterTerminate(@NonNull Action onAfterTerminate) |
Registers an Action to be called when this Publisher invokes either
onComplete or onError .
|
@NonNull Flowable<T> |
Flowable.doFinally(@NonNull Action onFinally) |
Calls the specified action after this Flowable signals onError or onComplete or gets canceled by
the downstream.
|
@NonNull Flowable<T> |
Flowable.doOnCancel(@NonNull Action onCancel) |
Calls the cancel Action if the downstream cancels the sequence.
|
@NonNull Flowable<T> |
Flowable.doOnComplete(@NonNull Action onComplete) |
Invokes an Action just before the current Flowable calls onComplete .
|
private @NonNull Flowable<T> |
Flowable.doOnEach(@NonNull Consumer<? super @NonNull T> onNext,
@NonNull Consumer<? super java.lang.Throwable> onError,
Action onComplete,
Action onAfterTerminate) |
Calls the appropriate onXXX consumer (shared between all subscribers) whenever a signal with the same type
passes through, before forwarding them to downstream.
|
@NonNull Flowable<T> |
Flowable.doOnEach(@NonNull Consumer<? super Notification<@NonNull T>> onNotification) |
Invokes a Consumer with a Notification instances matching the signals emitted by the current Flowable
before they are forwarded to the downstream.
|
@NonNull Flowable<T> |
Flowable.doOnEach(@NonNull org.reactivestreams.Subscriber<? super @NonNull T> subscriber) |
Calls the appropriate methods of the given Subscriber when the current Flowable signals events before forwarding it
to the downstream.
|
@NonNull Flowable<T> |
Flowable.doOnError(@NonNull Consumer<? super java.lang.Throwable> onError) |
Calls the given Consumer with the error Throwable if the current Flowable failed before forwarding it to
the downstream.
|
@NonNull Flowable<T> |
Flowable.doOnLifecycle(@NonNull Consumer<? super org.reactivestreams.Subscription> onSubscribe,
@NonNull LongConsumer onRequest,
@NonNull Action onCancel) |
Calls the appropriate onXXX method (shared between all Subscriber s) for the lifecycle events of
the sequence (subscription, cancellation, requesting).
|
@NonNull Flowable<T> |
Flowable.doOnNext(@NonNull Consumer<? super @NonNull T> onNext) |
Calls the given Consumer with the value emitted by the current Flowable before forwarding it to the downstream.
|
@NonNull Flowable<T> |
Flowable.doOnRequest(@NonNull LongConsumer onRequest) |
Calls the given LongConsumer with the request amount from the downstream before forwarding it
to the current Flowable .
|
@NonNull Flowable<T> |
Flowable.doOnSubscribe(@NonNull Consumer<? super org.reactivestreams.Subscription> onSubscribe) |
Calls the given Consumer with the Subscription provided by the current Flowable upon
subscription from the downstream before forwarding it to the subscriber's
onSubscribe method.
|
@NonNull Flowable<T> |
Flowable.doOnTerminate(@NonNull Action onTerminate) |
Calls the given Action when the current Flowable completes normally or with an error before those signals
are forwarded to the downstream.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.empty() |
Returns a Flowable that emits no items to the Subscriber and immediately invokes its
onComplete method.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.error(@NonNull Supplier<? extends @NonNull java.lang.Throwable> supplier) |
Returns a Flowable that invokes a Subscriber 's onError method when the
Subscriber subscribes to it.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.error(@NonNull java.lang.Throwable throwable) |
Returns a Flowable that invokes a Subscriber 's onError method when the
Subscriber subscribes to it.
|
@NonNull Flowable<T> |
Flowable.filter(@NonNull Predicate<? super @NonNull T> predicate) |
Filters items emitted by the current Flowable by only emitting those that satisfy a specified predicate.
|
<@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 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 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 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 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 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 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 .
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.fromAction(@NonNull Action action) |
Returns a Flowable instance that runs the given Action for each Subscriber and
emits either its exception or simply completes.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.fromArray(@NonNull T... items) |
Converts an array into a Publisher that emits the items in the array.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.fromCallable(@NonNull java.util.concurrent.Callable<? extends @NonNull T> callable) |
Returns a Flowable that, when a Subscriber subscribes to it, invokes a function you specify and then
emits the value returned from that function.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.fromCompletable(@NonNull CompletableSource completableSource) |
|
static <@NonNull T> @NonNull Flowable<@NonNull T> |
Flowable.fromCompletionStage(@NonNull java.util.concurrent.CompletionStage<@NonNull T> stage) |
Signals the completion value or error of the given (hot) CompletionStage -based asynchronous calculation.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.fromFuture(@NonNull java.util.concurrent.Future<? extends @NonNull T> future) |
Converts a Future into a Publisher .
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.fromFuture(@NonNull java.util.concurrent.Future<? extends @NonNull T> future,
long timeout,
@NonNull java.util.concurrent.TimeUnit unit) |
Converts a Future into a Publisher , with a timeout on the Future .
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.fromIterable(@NonNull java.lang.Iterable<? extends @NonNull T> source) |
Converts an Iterable sequence into a Publisher that emits the items in the sequence.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.fromMaybe(@NonNull MaybeSource<@NonNull T> maybe) |
Returns a Flowable instance that when subscribed to, subscribes to the MaybeSource instance and
emits onSuccess as a single item or forwards any onComplete or
onError signal.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.fromObservable(@NonNull ObservableSource<@NonNull T> source,
@NonNull BackpressureStrategy strategy) |
Converts the given ObservableSource into a Flowable by applying the specified backpressure strategy.
|
static <@NonNull T> @NonNull Flowable<@NonNull T> |
Flowable.fromOptional(@NonNull java.util.Optional<@NonNull T> optional) |
Converts the existing value of the provided optional into a just(Object)
or an empty optional into an empty() Flowable instance.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.fromPublisher(@NonNull org.reactivestreams.Publisher<? extends @NonNull T> publisher) |
Converts an arbitrary Reactive Streams Publisher into a Flowable if not already a
Flowable .
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.fromRunnable(@NonNull java.lang.Runnable run) |
Returns a Flowable instance that runs the given Runnable for each Subscriber and
emits either its unchecked exception or simply completes.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.fromSingle(@NonNull SingleSource<@NonNull T> source) |
Returns a Flowable instance that when subscribed to, subscribes to the SingleSource instance and
emits onSuccess as a single item or forwards the onError signal.
|
static <@NonNull T> @NonNull Flowable<@NonNull T> |
Flowable.fromStream(@NonNull java.util.stream.Stream<@NonNull T> stream) |
Converts a Stream into a finite Flowable and emits its items in the sequence.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.fromSupplier(@NonNull Supplier<? extends @NonNull T> supplier) |
Returns a Flowable that, when a Subscriber subscribes to it, invokes a supplier function you specify and then
emits the value returned from that function.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.generate(@NonNull Consumer<@NonNull Emitter<@NonNull T>> generator) |
Returns a cold, synchronous, stateless and backpressure-aware generator of values.
|
static <@NonNull T,@NonNull S> @NonNull Flowable<T> |
Flowable.generate(@NonNull Supplier<@NonNull S> initialState,
@NonNull BiConsumer<@NonNull S,Emitter<@NonNull T>> generator) |
Returns a cold, synchronous, stateful and backpressure-aware generator of values.
|
static <@NonNull T,@NonNull S> @NonNull Flowable<T> |
Flowable.generate(@NonNull Supplier<@NonNull S> initialState,
@NonNull BiConsumer<@NonNull S,Emitter<@NonNull T>> generator,
@NonNull Consumer<? super @NonNull S> disposeState) |
Returns a cold, synchronous, stateful and backpressure-aware generator of values.
|
static <@NonNull T,@NonNull S> @NonNull Flowable<T> |
Flowable.generate(@NonNull Supplier<@NonNull S> initialState,
@NonNull BiFunction<@NonNull S,@NonNull Emitter<@NonNull T>,@NonNull S> generator) |
Returns a cold, synchronous, stateful and backpressure-aware generator of values.
|
static <@NonNull T,@NonNull S> @NonNull Flowable<T> |
Flowable.generate(@NonNull Supplier<@NonNull S> initialState,
@NonNull BiFunction<@NonNull S,@NonNull Emitter<@NonNull T>,@NonNull S> generator,
@NonNull Consumer<? super @NonNull S> disposeState) |
Returns a cold, synchronous, stateful and backpressure-aware generator of values.
|
<@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 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 Flowable<T> |
Flowable.hide() |
Hides the identity of this Flowable and its Subscription .
|
static @NonNull Flowable<java.lang.Long> |
Flowable.interval(long initialDelay,
long period,
@NonNull java.util.concurrent.TimeUnit unit) |
Returns a Flowable that emits a 0L after the initialDelay and ever-increasing numbers
after each period of time thereafter.
|
static @NonNull Flowable<java.lang.Long> |
Flowable.interval(long initialDelay,
long period,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler) |
Returns a Flowable that emits a 0L after the initialDelay and ever-increasing numbers
after each period of time thereafter, on a specified Scheduler .
|
static @NonNull Flowable<java.lang.Long> |
Flowable.interval(long period,
@NonNull java.util.concurrent.TimeUnit unit) |
Returns a Flowable that emits a sequential number every specified interval of time.
|
static @NonNull Flowable<java.lang.Long> |
Flowable.interval(long period,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler) |
Returns a Flowable that emits a sequential number every specified interval of time, on a
specified Scheduler .
|
static @NonNull Flowable<java.lang.Long> |
Flowable.intervalRange(long start,
long count,
long initialDelay,
long period,
@NonNull java.util.concurrent.TimeUnit unit) |
Signals a range of long values, the first after some initial delay and the rest periodically after.
|
static @NonNull Flowable<java.lang.Long> |
Flowable.intervalRange(long start,
long count,
long initialDelay,
long period,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler) |
Signals a range of long values, the first after some initial delay and the rest periodically after.
|
<@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.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.just(@NonNull T item) |
Returns a Flowable that signals the given (constant reference) item and then completes.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.just(@NonNull T item1,
@NonNull T item2) |
Converts two items into a Publisher that emits those items.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.just(@NonNull T item1,
@NonNull T item2,
@NonNull T item3) |
Converts three items into a Publisher that emits those items.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.just(@NonNull T item1,
@NonNull T item2,
@NonNull T item3,
@NonNull T item4) |
Converts four items into a Publisher that emits those items.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.just(@NonNull T item1,
@NonNull T item2,
@NonNull T item3,
@NonNull T item4,
@NonNull T item5) |
Converts five items into a Publisher that emits those items.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.just(@NonNull T item1,
@NonNull T item2,
@NonNull T item3,
@NonNull T item4,
@NonNull T item5,
@NonNull T item6) |
Converts six items into a Publisher that emits those items.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.just(@NonNull T item1,
@NonNull T item2,
@NonNull T item3,
@NonNull T item4,
@NonNull T item5,
@NonNull T item6,
@NonNull T item7) |
Converts seven items into a Publisher that emits those items.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.just(@NonNull T item1,
@NonNull T item2,
@NonNull T item3,
@NonNull T item4,
@NonNull T item5,
@NonNull T item6,
@NonNull T item7,
@NonNull T item8) |
Converts eight items into a Publisher that emits those items.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.just(@NonNull T item1,
@NonNull T item2,
@NonNull T item3,
@NonNull T item4,
@NonNull T item5,
@NonNull T item6,
@NonNull T item7,
@NonNull T item8,
@NonNull T item9) |
Converts nine items into a Publisher that emits those items.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.just(@NonNull T item1,
@NonNull T item2,
@NonNull T item3,
@NonNull T item4,
@NonNull T item5,
@NonNull T item6,
@NonNull T item7,
@NonNull T item8,
@NonNull T item9,
@NonNull T item10) |
Converts ten items into a Publisher that emits those items.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.lift(@NonNull FlowableOperator<? extends @NonNull R,? super @NonNull T> lifter) |
This method requires advanced knowledge about building operators, please consider
other standard composition methods first;
Returns a Flowable which, when subscribed to, invokes the apply(Subscriber) method
of the provided FlowableOperator for each individual downstream Subscriber and allows the
insertion of a custom operator by accessing the downstream's Subscriber during this subscription phase
and providing a new Subscriber , containing the custom operator's intended business logic, that will be
used in the subscription process going further upstream.
|
<@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 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 Flowable<Notification<T>> |
Flowable.materialize() |
Returns a Flowable that represents all of the emissions and notifications from the current
Flowable into emissions marked with their original types within Notification objects.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.merge(@NonNull java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources) |
Flattens an Iterable of Publisher s into one Publisher , without any transformation.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.merge(@NonNull java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources,
int maxConcurrency) |
Flattens an Iterable of Publisher s into one Publisher , without any transformation, while limiting the
number of concurrent subscriptions to these Publisher s.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.merge(@NonNull java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources,
int maxConcurrency,
int bufferSize) |
Flattens an Iterable of Publisher s into one Publisher , without any transformation, while limiting the
number of concurrent subscriptions to these Publisher s.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.merge(@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source1,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source2) |
Flattens two Publisher s into a single Publisher , without any transformation.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.merge(@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source1,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source2,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source3) |
Flattens three Publisher s into a single Publisher , without any transformation.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.merge(@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source1,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source2,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source3,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source4) |
Flattens four Publisher s into a single Publisher , without any transformation.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.merge(@NonNull org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources) |
Flattens a Publisher that emits Publisher s into a single Publisher that emits the items emitted by
thos Publisher s , without any transformation.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.merge(@NonNull org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources,
int maxConcurrency) |
Flattens a Publisher that emits Publisher s into a single Publisher that emits the items emitted by
those Publisher s, without any transformation, while limiting the maximum number of concurrent
subscriptions to these Publisher s.
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.merge(@NonNull MaybeSource<? extends @NonNull T> source1,
@NonNull MaybeSource<? extends @NonNull T> source2) |
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.merge(@NonNull MaybeSource<? extends @NonNull T> source1,
@NonNull MaybeSource<? extends @NonNull T> source2,
@NonNull MaybeSource<? extends @NonNull T> source3) |
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.merge(@NonNull MaybeSource<? extends @NonNull T> source1,
@NonNull MaybeSource<? extends @NonNull T> source2,
@NonNull MaybeSource<? extends @NonNull T> source3,
@NonNull MaybeSource<? extends @NonNull T> source4) |
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.merge(@NonNull java.lang.Iterable<? extends MaybeSource<? extends @NonNull T>> sources) |
Merges an Iterable sequence of MaybeSource instances into a single Flowable sequence,
running all MaybeSource s at once.
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.merge(@NonNull org.reactivestreams.Publisher<? extends MaybeSource<? extends @NonNull T>> sources) |
Merges a Publisher sequence of MaybeSource instances into a single Flowable sequence,
running all MaybeSource s at once.
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.merge(@NonNull org.reactivestreams.Publisher<? extends MaybeSource<? extends @NonNull T>> sources,
int maxConcurrency) |
Merges a Publisher sequence of MaybeSource instances into a single Flowable sequence,
running at most maxConcurrency MaybeSource s at once.
|
static <@NonNull T> @NonNull Flowable<T> |
Single.merge(@NonNull SingleSource<? extends @NonNull T> source1,
@NonNull SingleSource<? extends @NonNull T> source2) |
|
static <@NonNull T> @NonNull Flowable<T> |
Single.merge(@NonNull SingleSource<? extends @NonNull T> source1,
@NonNull SingleSource<? extends @NonNull T> source2,
@NonNull SingleSource<? extends @NonNull T> source3) |
|
static <@NonNull T> @NonNull Flowable<T> |
Single.merge(@NonNull SingleSource<? extends @NonNull T> source1,
@NonNull SingleSource<? extends @NonNull T> source2,
@NonNull SingleSource<? extends @NonNull T> source3,
@NonNull SingleSource<? extends @NonNull T> source4) |
|
static <@NonNull T> @NonNull Flowable<T> |
Single.merge(@NonNull java.lang.Iterable<? extends SingleSource<? extends @NonNull T>> sources) |
Merges an Iterable sequence of SingleSource instances into a single Flowable sequence,
running all SingleSource s at once.
|
static <@NonNull T> @NonNull Flowable<T> |
Single.merge(@NonNull org.reactivestreams.Publisher<? extends SingleSource<? extends @NonNull T>> sources) |
Merges a sequence of SingleSource instances emitted by a Publisher into a single Flowable sequence,
running all SingleSource s at once.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.mergeArray(int maxConcurrency,
int bufferSize,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T>... sources) |
Flattens an array of Publisher s into one Publisher , without any transformation, while limiting the
number of concurrent subscriptions to these Publisher s.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.mergeArray(@NonNull org.reactivestreams.Publisher<? extends @NonNull T>... sources) |
Flattens an array of Publisher s into one Publisher , without any transformation.
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.mergeArray(MaybeSource<? extends @NonNull T>... sources) |
Merges an array of MaybeSource instances into a single Flowable sequence,
running all MaybeSource s at once.
|
static <@NonNull T> @NonNull Flowable<T> |
Single.mergeArray(SingleSource<? extends @NonNull T>... sources) |
Merges an array of SingleSource instances into a single Flowable sequence,
running all SingleSource s at once.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.mergeArrayDelayError(int maxConcurrency,
int bufferSize,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T>... sources) |
Flattens an array of Publisher s into one Publisher , in a way that allows a Subscriber to receive all
successfully emitted items from each of the source Publisher s without being interrupted by an error
notification from one of them, while limiting the number of concurrent subscriptions to these Publisher s.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.mergeArrayDelayError(@NonNull org.reactivestreams.Publisher<? extends @NonNull T>... sources) |
Flattens an array of Publisher s into one Flowable , in a way that allows a Subscriber to receive all
successfully emitted items from each of the source Publisher s without being interrupted by an error
notification from one of them.
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.mergeArrayDelayError(@NonNull MaybeSource<? extends @NonNull T>... sources) |
Flattens an array of MaybeSource s into one Flowable , in a way that allows a subscriber to receive all
successfully emitted items from each of the source MaybeSource s without being interrupted by an error
notification from one of them.
|
static <@NonNull T> @NonNull Flowable<T> |
Single.mergeArrayDelayError(@NonNull SingleSource<? extends @NonNull T>... sources) |
Flattens an array of SingleSource s into one Flowable , in a way that allows a subscriber to receive all
successfully emitted items from each of the source SingleSource s without being interrupted by an error
notification from one of them.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.mergeDelayError(@NonNull java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources) |
Flattens an Iterable of Publisher s into one Publisher , in a way that allows a Subscriber to receive all
successfully emitted items from each of the source Publisher s without being interrupted by an error
notification from one of them.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.mergeDelayError(@NonNull java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources,
int maxConcurrency) |
Flattens an Iterable of Publisher s into one Publisher , in a way that allows a Subscriber to receive all
successfully emitted items from each of the source Publisher s without being interrupted by an error
notification from one of them, while limiting the number of concurrent subscriptions to these Publisher s.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.mergeDelayError(@NonNull java.lang.Iterable<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources,
int maxConcurrency,
int bufferSize) |
Flattens an Iterable of Publisher s into one Publisher , in a way that allows a Subscriber to receive all
successfully emitted items from each of the source Publisher s without being interrupted by an error
notification from one of them, while limiting the number of concurrent subscriptions to these Publisher s.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.mergeDelayError(@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source1,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source2) |
Flattens two Publisher s into one Publisher , in a way that allows a Subscriber to receive all
successfully emitted items from each of the source Publisher s without being interrupted by an error
notification from one of them.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.mergeDelayError(@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source1,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source2,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source3) |
Flattens three Publisher s into one Publisher , in a way that allows a Subscriber to receive all
successfully emitted items from all of the source Publisher s without being interrupted by an error
notification from one of them.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.mergeDelayError(@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source1,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source2,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source3,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source4) |
Flattens four Publisher s into one Publisher , in a way that allows a Subscriber to receive all
successfully emitted items from all of the source Publisher s without being interrupted by an error
notification from one of them.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.mergeDelayError(@NonNull org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources) |
Flattens a Publisher that emits Publisher s into one Publisher , in a way that allows a Subscriber to
receive all successfully emitted items from all of the source Publisher s without being interrupted by
an error notification from one of them.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.mergeDelayError(@NonNull org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources,
int maxConcurrency) |
Flattens a Publisher that emits Publisher s into one Publisher , in a way that allows a Subscriber to
receive all successfully emitted items from all of the source Publisher s without being interrupted by
an error notification from one of them, while limiting the
number of concurrent subscriptions to these Publisher s.
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.mergeDelayError(@NonNull MaybeSource<? extends @NonNull T> source1,
@NonNull MaybeSource<? extends @NonNull T> source2) |
Flattens two MaybeSource s into one Flowable , in a way that allows a subscriber to receive all
successfully emitted items from each of the source MaybeSource s without being interrupted by an error
notification from one of them.
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.mergeDelayError(@NonNull MaybeSource<? extends @NonNull T> source1,
@NonNull MaybeSource<? extends @NonNull T> source2,
@NonNull MaybeSource<? extends @NonNull T> source3) |
Flattens three MaybeSource into one Flowable , in a way that allows a subscriber to receive all
successfully emitted items from all of the source MaybeSource s without being interrupted by an error
notification from one of them.
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.mergeDelayError(@NonNull MaybeSource<? extends @NonNull T> source1,
@NonNull MaybeSource<? extends @NonNull T> source2,
@NonNull MaybeSource<? extends @NonNull T> source3,
@NonNull MaybeSource<? extends @NonNull T> source4) |
Flattens four MaybeSource s into one Flowable , in a way that allows a subscriber to receive all
successfully emitted items from all of the source MaybeSource s without being interrupted by an error
notification from one of them.
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.mergeDelayError(@NonNull java.lang.Iterable<? extends MaybeSource<? extends @NonNull T>> sources) |
Flattens an Iterable sequence of MaybeSource s into one Flowable , in a way that allows a subscriber to receive all
successfully emitted items from each of the source MaybeSource s without being interrupted by an error
notification from one of them.
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.mergeDelayError(@NonNull org.reactivestreams.Publisher<? extends MaybeSource<? extends @NonNull T>> sources) |
Flattens a Publisher that emits MaybeSource s into one Flowable , in a way that allows a subscriber to
receive all successfully emitted items from all of the source MaybeSource s without being interrupted by
an error notification from one of them or even the main Publisher .
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.mergeDelayError(@NonNull org.reactivestreams.Publisher<? extends MaybeSource<? extends @NonNull T>> sources,
int maxConcurrency) |
Flattens a Publisher that emits MaybeSource s into one Flowable , in a way that allows a subscriber to
receive all successfully emitted items from all of the source MaybeSource s without being interrupted by
an error notification from one of them or even the main Publisher as well as limiting the total number of active MaybeSource s.
|
static <@NonNull T> @NonNull Flowable<T> |
Single.mergeDelayError(@NonNull SingleSource<? extends @NonNull T> source1,
@NonNull SingleSource<? extends @NonNull T> source2) |
Flattens two SingleSource s into one Flowable , without any transformation, delaying
any error(s) until all sources succeed or fail.
|
static <@NonNull T> @NonNull Flowable<T> |
Single.mergeDelayError(@NonNull SingleSource<? extends @NonNull T> source1,
@NonNull SingleSource<? extends @NonNull T> source2,
@NonNull SingleSource<? extends @NonNull T> source3) |
Flattens two SingleSource s into one Flowable , without any transformation, delaying
any error(s) until all sources succeed or fail.
|
static <@NonNull T> @NonNull Flowable<T> |
Single.mergeDelayError(@NonNull SingleSource<? extends @NonNull T> source1,
@NonNull SingleSource<? extends @NonNull T> source2,
@NonNull SingleSource<? extends @NonNull T> source3,
@NonNull SingleSource<? extends @NonNull T> source4) |
Flattens two SingleSource s into one Flowable , without any transformation, delaying
any error(s) until all sources succeed or fail.
|
static <@NonNull T> @NonNull Flowable<T> |
Single.mergeDelayError(@NonNull java.lang.Iterable<? extends SingleSource<? extends @NonNull T>> sources) |
Merges an Iterable sequence of SingleSource instances into one Flowable sequence,
running all SingleSource s at once and delaying any error(s) until all sources succeed or fail.
|
static <@NonNull T> @NonNull Flowable<T> |
Single.mergeDelayError(@NonNull org.reactivestreams.Publisher<? extends SingleSource<? extends @NonNull T>> sources) |
Merges a sequence of SingleSource instances emitted by a Publisher into a Flowable sequence,
running all SingleSource s at once and delaying any error(s) until all sources succeed or fail.
|
@NonNull Flowable<T> |
Flowable.mergeWith(@NonNull CompletableSource other) |
Relays the items of this Flowable and completes only when the other CompletableSource completes
as well.
|
@NonNull Flowable<T> |
Flowable.mergeWith(@NonNull MaybeSource<? extends @NonNull T> other) |
Merges the sequence of items of this Flowable with the success value of the other MaybeSource
or waits for both to complete normally if the MaybeSource is empty.
|
@NonNull Flowable<T> |
Flowable.mergeWith(@NonNull SingleSource<? extends @NonNull T> other) |
Merges the sequence of items of this Flowable with the success value of the other SingleSource .
|
@NonNull Flowable<T> |
Flowable.mergeWith(@NonNull org.reactivestreams.Publisher<? extends @NonNull T> other) |
Flattens this and another Publisher into a single Publisher , without any transformation.
|
@NonNull Flowable<T> |
Maybe.mergeWith(@NonNull MaybeSource<? extends @NonNull T> other) |
Flattens this Maybe and another MaybeSource into a single Flowable , without any transformation.
|
@NonNull Flowable<T> |
Single.mergeWith(@NonNull SingleSource<? extends @NonNull T> other) |
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.never() |
Returns a Flowable that never sends any items or notifications to a Subscriber .
|
@NonNull Flowable<T> |
Flowable.observeOn(@NonNull Scheduler scheduler) |
Signals the items and terminal signals of the current Flowable on the specified Scheduler ,
asynchronously with a bounded buffer of bufferSize() slots.
|
@NonNull Flowable<T> |
Flowable.observeOn(@NonNull Scheduler scheduler,
boolean delayError) |
Signals the items and terminal signals of the current Flowable on the specified Scheduler ,
asynchronously with a bounded buffer and optionally delays onError notifications.
|
@NonNull Flowable<T> |
Flowable.observeOn(@NonNull Scheduler scheduler,
boolean delayError,
int bufferSize) |
Signals the items and terminal signals of the current Flowable on the specified Scheduler ,
asynchronously with a bounded buffer of configurable size and optionally delays onError notifications.
|
<@NonNull U> @NonNull Flowable<U> |
Flowable.ofType(@NonNull java.lang.Class<@NonNull U> clazz) |
Filters the items emitted by the current Flowable , only emitting those of the specified type.
|
@NonNull Flowable<T> |
Flowable.onBackpressureBuffer() |
Buffers an unlimited number of items from the current Flowable and allows it to emit as fast it can while allowing the
downstream to consume the items at its own place.
|
@NonNull Flowable<T> |
Flowable.onBackpressureBuffer(boolean delayError) |
Buffers an unlimited number of items from the current Flowable and allows it to emit as fast it can while allowing the
downstream to consume the items at its own place, optionally delaying an error until all buffered items have been consumed.
|
@NonNull Flowable<T> |
Flowable.onBackpressureBuffer(int capacity) |
Buffers an limited number of items from the current Flowable and allows it to emit as fast it can while allowing the
downstream to consume the items at its own place, however, the resulting Flowable will signal a
MissingBackpressureException via onError as soon as the buffer's capacity is exceeded, dropping all undelivered
items, and canceling the flow.
|
@NonNull Flowable<T> |
Flowable.onBackpressureBuffer(int capacity,
boolean delayError) |
Buffers an limited number of items from the current Flowable and allows it to emit as fast it can while allowing the
downstream to consume the items at its own place, however, the resulting Flowable will signal a
MissingBackpressureException via onError as soon as the buffer's capacity is exceeded, dropping all undelivered
items, and canceling the flow.
|
@NonNull Flowable<T> |
Flowable.onBackpressureBuffer(int capacity,
boolean delayError,
boolean unbounded) |
Buffers an optionally unlimited number of items from the current Flowable and allows it to emit as fast it can while allowing the
downstream to consume the items at its own place.
|
@NonNull Flowable<T> |
Flowable.onBackpressureBuffer(int capacity,
boolean delayError,
boolean unbounded,
@NonNull Action onOverflow) |
Buffers an optionally unlimited number of items from the current Flowable and allows it to emit as fast it can while allowing the
downstream to consume the items at its own place.
|
@NonNull Flowable<T> |
Flowable.onBackpressureBuffer(int capacity,
boolean delayError,
boolean unbounded,
@NonNull Action onOverflow,
@NonNull Consumer<? super @NonNull T> onDropped) |
Buffers an optionally unlimited number of items from the current Flowable and allows it to emit as fast it can while allowing the
downstream to consume the items at its own place.
|
@NonNull Flowable<T> |
Flowable.onBackpressureBuffer(int capacity,
@NonNull Action onOverflow) |
Buffers an limited number of items from the current Flowable and allows it to emit as fast it can while allowing the
downstream to consume the items at its own place, however, the resulting Flowable will signal a
MissingBackpressureException via onError as soon as the buffer's capacity is exceeded, dropping all undelivered
items, canceling the flow and calling the onOverflow action.
|
@NonNull Flowable<T> |
Flowable.onBackpressureBuffer(long capacity,
@Nullable Action onOverflow,
@NonNull BackpressureOverflowStrategy overflowStrategy) |
Buffers an optionally unlimited number of items from the current Flowable and allows it to emit as fast it can while allowing the
downstream to consume the items at its own place.
|
@NonNull Flowable<T> |
Flowable.onBackpressureBuffer(long capacity,
@Nullable Action onOverflow,
@NonNull BackpressureOverflowStrategy overflowStrategy,
@NonNull Consumer<? super @NonNull T> onDropped) |
Buffers an optionally unlimited number of items from the current Flowable and allows it to emit as fast it can while allowing the
downstream to consume the items at its own place.
|
@NonNull Flowable<T> |
Flowable.onBackpressureDrop() |
Drops items from the current Flowable if the downstream is not ready to receive new items (indicated
by a lack of Subscription.request(long) calls from it).
|
@NonNull Flowable<T> |
Flowable.onBackpressureDrop(@NonNull Consumer<? super @NonNull T> onDrop) |
Drops items from the current Flowable if the downstream is not ready to receive new items (indicated
by a lack of Subscription.request(long) calls from it) and calls the given Consumer with such
dropped items.
|
@NonNull Flowable<T> |
Flowable.onBackpressureLatest() |
Drops all but the latest item emitted by the current Flowable if the downstream is not ready to receive
new items (indicated by a lack of Subscription.request(long) calls from it) and emits this latest
item when the downstream becomes ready.
|
@NonNull Flowable<T> |
Flowable.onBackpressureLatest(@NonNull Consumer<? super @NonNull T> onDropped) |
Drops all but the latest item emitted by the current Flowable if the downstream is not ready to receive
new items (indicated by a lack of Subscription.request(long) calls from it) and emits this latest
item when the downstream becomes ready.
|
@NonNull Flowable<T> |
Flowable.onBackpressureReduce(@NonNull BiFunction<@NonNull T,@NonNull T,@NonNull T> reducer) |
Reduces a sequence of two not emitted values via a function into a single value if the downstream is not ready to receive
new items (indicated by a lack of Subscription.request(long) calls from it) and emits this latest
item when the downstream becomes ready.
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.onBackpressureReduce(@NonNull Supplier<@NonNull R> supplier,
@NonNull BiFunction<@NonNull R,? super @NonNull T,@NonNull R> reducer) |
Reduces upstream values into an aggregate value, provided by a supplier and combined via a reducer function,
while the downstream is not ready to receive items, then emits this aggregate value when the downstream becomes ready.
|
@NonNull Flowable<T> |
Flowable.onErrorComplete() |
Returns a Flowable instance that if the current Flowable emits an error, it will emit an onComplete
and swallow the throwable.
|
@NonNull Flowable<T> |
Flowable.onErrorComplete(@NonNull Predicate<? super java.lang.Throwable> predicate) |
Returns a Flowable instance that if the current Flowable emits an error and the predicate returns
true , it will emit an onComplete and swallow the throwable.
|
@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 Flowable<T> |
Flowable.onErrorResumeWith(@NonNull org.reactivestreams.Publisher<? extends @NonNull T> fallback) |
Resumes the flow with the given Publisher when the current Flowable fails 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 Flowable<T> |
Flowable.onErrorReturnItem(@NonNull T item) |
Ends the flow with the given last item when the current Flowable fails instead of signaling the error via onError .
|
@NonNull Flowable<T> |
Flowable.onTerminateDetach() |
Nulls out references to the upstream producer and downstream Subscriber if
the sequence is terminated or downstream cancels.
|
<@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.
|
static @NonNull Flowable<java.lang.Integer> |
Flowable.range(int start,
int count) |
Returns a Flowable that emits a sequence of Integer s within a specified range.
|
static @NonNull Flowable<java.lang.Long> |
Flowable.rangeLong(long start,
long count) |
Returns a Flowable that emits a sequence of Long s within a specified range.
|
@NonNull Flowable<T> |
Flowable.rebatchRequests(int n) |
Requests n initially from the upstream and then 75% of n subsequently
after 75% of n values have been emitted to the downstream.
|
@NonNull Flowable<T> |
Flowable.repeat() |
Returns a Flowable that repeats the sequence of items emitted by the current Flowable indefinitely.
|
@NonNull Flowable<T> |
Flowable.repeat(long times) |
Returns a Flowable that repeats the sequence of items emitted by the current Flowable at most
count times.
|
@NonNull Flowable<T> |
Maybe.repeat() |
Returns a Flowable that repeats the sequence of items emitted by the current Maybe indefinitely.
|
@NonNull Flowable<T> |
Maybe.repeat(long times) |
Returns a Flowable that repeats the sequence of items emitted by the current Maybe at most
count times.
|
@NonNull Flowable<T> |
Single.repeat() |
Repeatedly re-subscribes to the current Single and emits each success value as a Flowable sequence.
|
@NonNull Flowable<T> |
Single.repeat(long times) |
Re-subscribes to the current Single at most the given number of times and emits each success value as a Flowable sequence.
|
@NonNull Flowable<T> |
Flowable.repeatUntil(@NonNull BooleanSupplier stop) |
Returns a Flowable that repeats the sequence of items emitted by the current Flowable until
the provided stop function returns true .
|
@NonNull Flowable<T> |
Maybe.repeatUntil(@NonNull BooleanSupplier stop) |
Returns a Flowable that repeats the sequence of items emitted by the current Maybe until
the provided stop function returns true .
|
@NonNull Flowable<T> |
Single.repeatUntil(@NonNull BooleanSupplier stop) |
Re-subscribes to the current Single until the given BooleanSupplier returns true
and emits the success items as a Flowable sequence.
|
@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 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 Flowable<T> |
Flowable.retry() |
Returns a Flowable that mirrors the current Flowable , resubscribing to it if it calls onError
(infinite retry count).
|
@NonNull Flowable<T> |
Flowable.retry(long times) |
Returns a Flowable that mirrors the current Flowable , resubscribing to it if it calls onError
up to a specified number of retries.
|
@NonNull Flowable<T> |
Flowable.retry(long times,
@NonNull Predicate<? super java.lang.Throwable> predicate) |
Retries at most times or until the predicate returns false , whichever happens first.
|
@NonNull Flowable<T> |
Flowable.retry(@NonNull BiPredicate<? super java.lang.Integer,? super java.lang.Throwable> predicate) |
Returns a Flowable that mirrors the current Flowable , resubscribing to it if it calls onError
and the predicate returns true for that specific exception and retry count.
|
@NonNull Flowable<T> |
Flowable.retry(@NonNull Predicate<? super java.lang.Throwable> predicate) |
Retries the current Flowable if the predicate returns true .
|
@NonNull Flowable<T> |
Flowable.retryUntil(@NonNull BooleanSupplier stop) |
Retries until the given stop function returns true .
|
@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 Flowable<T> |
Flowable.sample(long period,
@NonNull java.util.concurrent.TimeUnit unit) |
Returns a Flowable that emits the most recently emitted item (if any) emitted by the current Flowable
within periodic time intervals.
|
@NonNull Flowable<T> |
Flowable.sample(long period,
@NonNull java.util.concurrent.TimeUnit unit,
boolean emitLast) |
Returns a Flowable that emits the most recently emitted item (if any) emitted by the current Flowable
within periodic time intervals and optionally emit the very last upstream item when the upstream completes.
|
@NonNull Flowable<T> |
Flowable.sample(long period,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler) |
Returns a Flowable that emits the most recently emitted item (if any) emitted by the current Flowable
within periodic time intervals, where the intervals are defined on a particular Scheduler .
|
@NonNull Flowable<T> |
Flowable.sample(long period,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
boolean emitLast) |
Returns a Flowable that emits the most recently emitted item (if any) emitted by the current Flowable
within periodic time intervals, where the intervals are defined on a particular Scheduler
and optionally emit the very last upstream item when the upstream completes.
|
@NonNull Flowable<T> |
Flowable.sample(long period,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
boolean emitLast,
@NonNull Consumer<? super @NonNull T> onDropped) |
Returns a Flowable that emits the most recently emitted item (if any) emitted by the current Flowable
within periodic time intervals, where the intervals are defined on a particular Scheduler
and optionally emit the very last upstream item when the upstream completes.
|
<@NonNull U> @NonNull Flowable<T> |
Flowable.sample(@NonNull org.reactivestreams.Publisher<@NonNull U> sampler) |
Returns a Flowable that, when the specified sampler Publisher emits an item or completes,
emits the most recently emitted item (if any) emitted by the current Flowable since the previous
emission from the sampler Publisher .
|
<@NonNull U> @NonNull Flowable<T> |
Flowable.sample(@NonNull org.reactivestreams.Publisher<@NonNull U> sampler,
boolean emitLast) |
Returns a Flowable that, when the specified sampler Publisher emits an item or completes,
emits the most recently emitted item (if any) emitted by the current Flowable since the previous
emission from the sampler Publisher
and optionally emit the very last upstream item when the upstream or other Publisher complete.
|
@NonNull Flowable<T> |
Flowable.scan(@NonNull BiFunction<@NonNull T,@NonNull T,@NonNull T> accumulator) |
Returns a Flowable that emits the first value emitted by the current Flowable , then emits one value
for each subsequent value emitted by the current Flowable .
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.scan(@NonNull R initialValue,
@NonNull BiFunction<@NonNull R,? super @NonNull T,@NonNull R> accumulator) |
Returns a Flowable that emits the provided initial (seed) value, then emits one value for each value emitted
by the current Flowable .
|
<@NonNull R> @NonNull Flowable<R> |
Flowable.scanWith(@NonNull Supplier<@NonNull R> seedSupplier,
@NonNull BiFunction<@NonNull R,? super @NonNull T,@NonNull R> accumulator) |
Returns a Flowable that emits the provided initial (seed) value, then emits one value for each value emitted
by the current Flowable .
|
@NonNull Flowable<T> |
Flowable.serialize() |
Forces the current Flowable 's emissions and notifications to be serialized and for it to obey
the Publisher contract in other ways.
|
@NonNull Flowable<T> |
Flowable.share() |
Returns a new Flowable that multicasts (and shares a single subscription to) the current Flowable .
|
@NonNull Flowable<T> |
Flowable.skip(long count) |
Returns a Flowable that skips the first count items emitted by the current Flowable and emits
the remainder.
|
@NonNull Flowable<T> |
Flowable.skip(long time,
@NonNull java.util.concurrent.TimeUnit unit) |
Returns a Flowable that skips values emitted by the current Flowable before a specified time window
elapses.
|
@NonNull Flowable<T> |
Flowable.skip(long time,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler) |
Returns a Flowable that skips values emitted by the current Flowable before a specified time window
on a specified Scheduler elapses.
|
@NonNull Flowable<T> |
Flowable.skipLast(int count) |
Returns a Flowable that drops a specified number of items from the end of the sequence emitted by the
current Flowable .
|
@NonNull Flowable<T> |
Flowable.skipLast(long time,
@NonNull java.util.concurrent.TimeUnit unit) |
Returns a Flowable that drops items emitted by the current Flowable during a specified time window
before the source completes.
|
@NonNull Flowable<T> |
Flowable.skipLast(long time,
@NonNull java.util.concurrent.TimeUnit unit,
boolean delayError) |
Returns a Flowable that drops items emitted by the current Flowable during a specified time window
before the source completes.
|
@NonNull Flowable<T> |
Flowable.skipLast(long time,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler) |
Returns a Flowable that drops items emitted by the current Flowable during a specified time window
(defined on a specified scheduler) before the source completes.
|
@NonNull Flowable<T> |
Flowable.skipLast(long time,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
boolean delayError) |
Returns a Flowable that drops items emitted by the current Flowable during a specified time window
(defined on a specified scheduler) before the source completes.
|
@NonNull Flowable<T> |
Flowable.skipLast(long time,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
boolean delayError,
int bufferSize) |
Returns a Flowable that drops items emitted by the current Flowable during a specified time window
(defined on a specified scheduler) before the source completes.
|
<@NonNull U> @NonNull Flowable<T> |
Flowable.skipUntil(@NonNull org.reactivestreams.Publisher<@NonNull U> other) |
Returns a Flowable that skips items emitted by the current Flowable until a second Publisher emits
an item.
|
@NonNull Flowable<T> |
Flowable.skipWhile(@NonNull Predicate<? super @NonNull T> predicate) |
Returns a Flowable that skips all items emitted by the current Flowable as long as a specified
condition holds true , but emits all further source items as soon as the condition becomes false .
|
@NonNull Flowable<T> |
Flowable.sorted() |
Returns a Flowable that emits the events emitted by source Publisher , in a
sorted order.
|
@NonNull Flowable<T> |
Flowable.sorted(@NonNull java.util.Comparator<? super @NonNull T> comparator) |
Returns a Flowable that emits the events emitted by source Publisher , in a
sorted order based on a specified comparison function.
|
<@NonNull T> @NonNull Flowable<T> |
Completable.startWith(@NonNull MaybeSource<@NonNull T> other) |
Returns a Flowable which first runs the other MaybeSource
then the current Completable if the other succeeded or completed normally.
|
<@NonNull T> @NonNull Flowable<T> |
Completable.startWith(@NonNull SingleSource<@NonNull T> other) |
Returns a Flowable which first runs the other SingleSource
then the current Completable if the other succeeded normally.
|
<@NonNull T> @NonNull Flowable<T> |
Completable.startWith(@NonNull org.reactivestreams.Publisher<@NonNull T> other) |
Returns a Flowable which first delivers the events
of the other Publisher then runs the current Completable .
|
@NonNull Flowable<T> |
Flowable.startWith(@NonNull CompletableSource other) |
Returns a Flowable which first runs the other CompletableSource
then the current Flowable if the other completed normally.
|
@NonNull Flowable<T> |
Flowable.startWith(@NonNull MaybeSource<@NonNull T> other) |
Returns a Flowable which first runs the other MaybeSource
then the current Flowable if the other succeeded or completed normally.
|
@NonNull Flowable<T> |
Flowable.startWith(@NonNull SingleSource<@NonNull T> other) |
Returns a Flowable which first runs the other SingleSource
then the current Flowable if the other succeeded normally.
|
@NonNull Flowable<T> |
Flowable.startWith(@NonNull org.reactivestreams.Publisher<? extends @NonNull T> other) |
Returns a Flowable that emits the items in a specified Publisher before it begins to emit
items emitted by the current Flowable .
|
@NonNull Flowable<T> |
Maybe.startWith(@NonNull CompletableSource other) |
|
@NonNull Flowable<T> |
Maybe.startWith(@NonNull MaybeSource<@NonNull T> other) |
Returns a Flowable which first runs the other MaybeSource
then the current Maybe if the other succeeded or completed normally.
|
@NonNull Flowable<T> |
Maybe.startWith(@NonNull SingleSource<@NonNull T> other) |
Returns a Flowable which first runs the other SingleSource
then the current Maybe if the other succeeded normally.
|
@NonNull Flowable<T> |
Maybe.startWith(@NonNull org.reactivestreams.Publisher<@NonNull T> other) |
Returns a Flowable which first delivers the events
of the other Publisher then runs the current Maybe .
|
@NonNull Flowable<T> |
Single.startWith(@NonNull CompletableSource other) |
|
@NonNull Flowable<T> |
Single.startWith(@NonNull MaybeSource<@NonNull T> other) |
Returns a Flowable which first runs the other MaybeSource
then the current Single if the other succeeded or completed normally.
|
@NonNull Flowable<T> |
Single.startWith(@NonNull SingleSource<@NonNull T> other) |
Returns a Flowable which first runs the other SingleSource
then the current Single if the other succeeded normally.
|
@NonNull Flowable<T> |
Single.startWith(@NonNull org.reactivestreams.Publisher<@NonNull T> other) |
Returns a Flowable which first delivers the events
of the other Publisher then runs the current Single .
|
@NonNull Flowable<T> |
Flowable.startWithArray(@NonNull T... items) |
Returns a Flowable that emits the specified items before it begins to emit items emitted by the current
Flowable .
|
@NonNull Flowable<T> |
Flowable.startWithItem(@NonNull T item) |
Returns a Flowable that emits a specified item before it begins to emit items emitted by the current
Flowable .
|
@NonNull Flowable<T> |
Flowable.startWithIterable(@NonNull java.lang.Iterable<? extends @NonNull T> items) |
Returns a Flowable that emits the items in a specified Iterable before it begins to emit items
emitted by the current Flowable .
|
@NonNull Flowable<T> |
Flowable.subscribeOn(@NonNull Scheduler scheduler) |
Asynchronously subscribes Subscriber s to the current Flowable on the specified Scheduler .
|
@NonNull Flowable<T> |
Flowable.subscribeOn(@NonNull Scheduler scheduler,
boolean requestOn) |
Asynchronously subscribes Subscriber s to the current Flowable on the specified Scheduler
optionally reroutes requests from other threads to the same Scheduler thread.
|
@NonNull Flowable<T> |
Flowable.switchIfEmpty(@NonNull org.reactivestreams.Publisher<? extends @NonNull T> other) |
Returns a Flowable that emits the items emitted by the current Flowable or the items of an alternate
Publisher if the current Flowable is empty.
|
<@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.
|
(package private) <R> Flowable<R> |
Flowable.switchMap0(Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
int bufferSize,
boolean delayError) |
|
<@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 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 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 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 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.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.switchOnNext(@NonNull org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources,
int bufferSize) |
Converts a Publisher that emits Publisher s into a Publisher that emits the items emitted by the
most recently emitted of those Publisher s.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.switchOnNext(@NonNull org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources) |
Converts a Publisher that emits Publisher s into a Publisher that emits the items emitted by the
most recently emitted of those Publisher s.
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.switchOnNext(@NonNull org.reactivestreams.Publisher<? extends MaybeSource<? extends @NonNull T>> sources) |
Switches between MaybeSource s emitted by the source Publisher whenever
a new MaybeSource is emitted, disposing the previously running MaybeSource ,
exposing the success items as a Flowable sequence.
|
static <@NonNull T> @NonNull Flowable<T> |
Single.switchOnNext(@NonNull org.reactivestreams.Publisher<? extends SingleSource<? extends @NonNull T>> sources) |
Switches between SingleSource s emitted by the source Publisher whenever
a new SingleSource is emitted, disposing the previously running SingleSource ,
exposing the success items as a Flowable sequence.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.switchOnNextDelayError(@NonNull org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources) |
Converts a Publisher that emits Publisher s into a Publisher that emits the items emitted by the
most recently emitted of those Publisher s and delays any exception until all Publisher s terminate.
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.switchOnNextDelayError(@NonNull org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources,
int prefetch) |
Converts a Publisher that emits Publisher s into a Publisher that emits the items emitted by the
most recently emitted of those Publisher s and delays any exception until all Publisher s terminate.
|
static <@NonNull T> @NonNull Flowable<T> |
Maybe.switchOnNextDelayError(@NonNull org.reactivestreams.Publisher<? extends MaybeSource<? extends @NonNull T>> sources) |
Switches between MaybeSource s emitted by the source Publisher whenever
a new MaybeSource is emitted, disposing the previously running MaybeSource ,
exposing the success items as a Flowable sequence and delaying all errors from
all of them until all terminate.
|
static <@NonNull T> @NonNull Flowable<T> |
Single.switchOnNextDelayError(@NonNull org.reactivestreams.Publisher<? extends SingleSource<? extends @NonNull T>> sources) |
Switches between SingleSource s emitted by the source Publisher whenever
a new SingleSource is emitted, disposing the previously running SingleSource ,
exposing the success items as a Flowable sequence and delaying all errors from
all of them until all terminate.
|
@NonNull Flowable<T> |
Flowable.take(long count) |
Returns a Flowable that emits only the first count items emitted by the current Flowable .
|
@NonNull Flowable<T> |
Flowable.take(long time,
@NonNull java.util.concurrent.TimeUnit unit) |
Returns a Flowable that emits those items emitted by source Publisher before a specified time runs
out.
|
@NonNull Flowable<T> |
Flowable.take(long time,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler) |
Returns a Flowable that emits those items emitted by source Publisher before a specified time (on a
specified Scheduler ) runs out.
|
@NonNull Flowable<T> |
Flowable.takeLast(int count) |
Returns a Flowable that emits at most the last count items emitted by the current Flowable .
|
@NonNull Flowable<T> |
Flowable.takeLast(long count,
long time,
@NonNull java.util.concurrent.TimeUnit unit) |
Returns a Flowable that emits at most a specified number of items from the current Flowable that were
emitted in a specified window of time before the current Flowable completed.
|
@NonNull Flowable<T> |
Flowable.takeLast(long count,
long time,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler) |
Returns a Flowable that emits at most a specified number of items from the current Flowable that were
emitted in a specified window of time before the current Flowable completed, where the timing information is
provided by a given Scheduler .
|
@NonNull Flowable<T> |
Flowable.takeLast(long count,
long time,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
boolean delayError,
int bufferSize) |
Returns a Flowable that emits at most a specified number of items from the current Flowable that were
emitted in a specified window of time before the current Flowable completed, where the timing information is
provided by a given Scheduler .
|
@NonNull Flowable<T> |
Flowable.takeLast(long time,
@NonNull java.util.concurrent.TimeUnit unit) |
Returns a Flowable that emits the items from the current Flowable that were emitted in a specified
window of time before the current Flowable completed.
|
@NonNull Flowable<T> |
Flowable.takeLast(long time,
@NonNull java.util.concurrent.TimeUnit unit,
boolean delayError) |
Returns a Flowable that emits the items from the current Flowable that were emitted in a specified
window of time before the current Flowable completed.
|
@NonNull Flowable<T> |
Flowable.takeLast(long time,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler) |
Returns a Flowable that emits the items from the current Flowable that were emitted in a specified
window of time before the current Flowable completed, where the timing information is provided by a specified
Scheduler .
|
@NonNull Flowable<T> |
Flowable.takeLast(long time,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
boolean delayError) |
Returns a Flowable that emits the items from the current Flowable that were emitted in a specified
window of time before the current Flowable completed, where the timing information is provided by a specified
Scheduler .
|
@NonNull Flowable<T> |
Flowable.takeLast(long time,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
boolean delayError,
int bufferSize) |
Returns a Flowable that emits the items from the current Flowable that were emitted in a specified
window of time before the current Flowable completed, where the timing information is provided by a specified
Scheduler .
|
@NonNull Flowable<T> |
Flowable.takeUntil(@NonNull Predicate<? super @NonNull T> stopPredicate) |
Returns a Flowable that emits items emitted by the current Flowable , checks the specified predicate
for each item, and then completes when the condition is satisfied.
|
<@NonNull U> @NonNull Flowable<T> |
Flowable.takeUntil(@NonNull org.reactivestreams.Publisher<@NonNull U> other) |
Returns a Flowable that emits the items emitted by the current Flowable until a second Publisher
emits an item or completes.
|
@NonNull Flowable<T> |
Flowable.takeWhile(@NonNull Predicate<? super @NonNull T> predicate) |
Returns a Flowable that emits items emitted by the current Flowable so long as each item satisfied a
specified condition, and then completes as soon as this condition is not satisfied.
|
@NonNull Flowable<T> |
Flowable.throttleFirst(long windowDuration,
@NonNull java.util.concurrent.TimeUnit unit) |
Returns a Flowable that emits only the first item emitted by the current Flowable during sequential
time windows of a specified duration.
|
@NonNull Flowable<T> |
Flowable.throttleFirst(long skipDuration,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler) |
Returns a Flowable that emits only the first item emitted by the current Flowable during sequential
time windows of a specified duration, where the windows are managed by a specified Scheduler .
|
@NonNull Flowable<T> |
Flowable.throttleFirst(long skipDuration,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
@NonNull Consumer<? super @NonNull T> onDropped) |
Returns a Flowable that emits only the first item emitted by the current Flowable during sequential
time windows of a specified duration, where the windows are managed by a specified Scheduler .
|
@NonNull Flowable<T> |
Flowable.throttleLast(long intervalDuration,
@NonNull java.util.concurrent.TimeUnit unit) |
Returns a Flowable that emits only the last item emitted by the current Flowable during sequential
time windows of a specified duration.
|
@NonNull Flowable<T> |
Flowable.throttleLast(long intervalDuration,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler) |
Returns a Flowable that emits only the last item emitted by the current Flowable during sequential
time windows of a specified duration, where the duration is governed by a specified Scheduler .
|
@NonNull Flowable<T> |
Flowable.throttleLast(long intervalDuration,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
@NonNull Consumer<? super @NonNull T> onDropped) |
Returns a Flowable that emits only the last item emitted by the current Flowable during sequential
time windows of a specified duration, where the duration is governed by a specified Scheduler .
|
@NonNull Flowable<T> |
Flowable.throttleLatest(long timeout,
@NonNull java.util.concurrent.TimeUnit unit) |
Throttles items from the upstream Flowable by first emitting the next
item from upstream, then periodically emitting the latest item (if any) when
the specified timeout elapses between them.
|
@NonNull Flowable<T> |
Flowable.throttleLatest(long timeout,
@NonNull java.util.concurrent.TimeUnit unit,
boolean emitLast) |
Throttles items from the upstream Flowable by first emitting the next
item from upstream, then periodically emitting the latest item (if any) when
the specified timeout elapses between them.
|
@NonNull Flowable<T> |
Flowable.throttleLatest(long timeout,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler) |
Throttles items from the upstream Flowable by first emitting the next
item from upstream, then periodically emitting the latest item (if any) when
the specified timeout elapses between them.
|
@NonNull Flowable<T> |
Flowable.throttleLatest(long timeout,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
boolean emitLast) |
Throttles items from the upstream Flowable by first emitting the next
item from upstream, then periodically emitting the latest item (if any) when
the specified timeout elapses between them.
|
@NonNull Flowable<T> |
Flowable.throttleLatest(long timeout,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
boolean emitLast,
@NonNull Consumer<? super @NonNull T> onDropped) |
Throttles items from the upstream Flowable by first emitting the next
item from upstream, then periodically emitting the latest item (if any) when
the specified timeout elapses between them, invoking the consumer for any dropped item.
|
@NonNull Flowable<T> |
Flowable.throttleWithTimeout(long timeout,
@NonNull java.util.concurrent.TimeUnit unit) |
Returns a Flowable that mirrors the current Flowable , except that it drops items emitted by the
current Flowable that are followed by newer items before a timeout value expires.
|
@NonNull Flowable<T> |
Flowable.throttleWithTimeout(long timeout,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler) |
Returns a Flowable that mirrors the current Flowable , except that it drops items emitted by the
current Flowable that are followed by newer items before a timeout value expires on a specified
Scheduler .
|
@NonNull Flowable<T> |
Flowable.throttleWithTimeout(long timeout,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
@NonNull Consumer<? super @NonNull T> onDropped) |
Returns a Flowable that mirrors the current Flowable , except that it drops items emitted by the
current Flowable that are followed by newer items before a timeout value expires on a specified
Scheduler .
|
@NonNull Flowable<Timed<T>> |
Flowable.timeInterval() |
Returns a Flowable that emits records of the time interval between consecutive items emitted by the
current Flowable .
|
@NonNull Flowable<Timed<T>> |
Flowable.timeInterval(@NonNull Scheduler scheduler) |
Returns a Flowable that emits records of the time interval between consecutive items emitted by the
current Flowable , where this interval is computed on a specified Scheduler .
|
@NonNull Flowable<Timed<T>> |
Flowable.timeInterval(@NonNull java.util.concurrent.TimeUnit unit) |
Returns a Flowable that emits records of the time interval between consecutive items emitted by the
current Flowable .
|
@NonNull Flowable<Timed<T>> |
Flowable.timeInterval(@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler) |
Returns a Flowable that emits records of the time interval between consecutive items emitted by the
current Flowable , where this interval is computed on a specified Scheduler .
|
@NonNull Flowable<T> |
Flowable.timeout(long timeout,
@NonNull java.util.concurrent.TimeUnit unit) |
Returns a Flowable that mirrors the current Flowable but applies a timeout policy for each emitted
item.
|
@NonNull Flowable<T> |
Flowable.timeout(long timeout,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler) |
Returns a Flowable that mirrors the current Flowable but applies a timeout policy for each emitted
item, where this policy is governed by a specified Scheduler .
|
@NonNull Flowable<T> |
Flowable.timeout(long timeout,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T> fallback) |
Returns a Flowable that mirrors the current Flowable but applies a timeout policy for each emitted
item using a specified Scheduler .
|
@NonNull Flowable<T> |
Flowable.timeout(long timeout,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T> fallback) |
Returns a Flowable that mirrors the current Flowable but applies a timeout policy for each emitted
item.
|
<@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.
|
private Flowable<T> |
Flowable.timeout0(long timeout,
java.util.concurrent.TimeUnit unit,
org.reactivestreams.Publisher<? extends @NonNull T> fallback,
Scheduler scheduler) |
|
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) |
|
static @NonNull Flowable<java.lang.Long> |
Flowable.timer(long delay,
@NonNull java.util.concurrent.TimeUnit unit) |
Returns a Flowable that emits 0L after a specified delay, and then completes.
|
static @NonNull Flowable<java.lang.Long> |
Flowable.timer(long delay,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler) |
Returns a Flowable that emits 0L after a specified delay, on a specified Scheduler , and then
completes.
|
@NonNull Flowable<Timed<T>> |
Flowable.timestamp() |
Returns a Flowable that emits each item emitted by the current Flowable , wrapped in a
Timed object.
|
@NonNull Flowable<Timed<T>> |
Flowable.timestamp(@NonNull Scheduler scheduler) |
Returns a Flowable that emits each item emitted by the current Flowable , wrapped in a
Timed object whose timestamps are provided by a specified Scheduler .
|
@NonNull Flowable<Timed<T>> |
Flowable.timestamp(@NonNull java.util.concurrent.TimeUnit unit) |
Returns a Flowable that emits each item emitted by the current Flowable , wrapped in a
Timed object.
|
@NonNull Flowable<Timed<T>> |
Flowable.timestamp(@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler) |
Returns a Flowable that emits each item emitted by the current Flowable , wrapped in a
Timed object whose timestamps are provided by a specified Scheduler .
|
<@NonNull T> @NonNull Flowable<T> |
Completable.toFlowable() |
Returns a Flowable which when subscribed to subscribes to this Completable and
relays the terminal events to the downstream Subscriber .
|
@NonNull Flowable<T> |
Maybe.toFlowable() |
Converts this Maybe into a backpressure-aware Flowable instance composing cancellation
through.
|
@NonNull Flowable<T> |
Observable.toFlowable(@NonNull BackpressureStrategy strategy) |
Converts the current Observable into a Flowable by applying the specified backpressure strategy.
|
@NonNull Flowable<T> |
Single.toFlowable() |
|
static <@NonNull T> @NonNull Flowable<T> |
Flowable.unsafeCreate(@NonNull org.reactivestreams.Publisher<@NonNull T> onSubscribe) |
Create a Flowable by wrapping a Publisher which has to be implemented according
to the Reactive Streams specification by handling backpressure and
cancellation correctly; no safeguards are provided by the Flowable itself.
|
@NonNull Flowable<T> |
Flowable.unsubscribeOn(@NonNull Scheduler scheduler) |
Cancels the current Flowable asynchronously by invoking Subscription.cancel()
on the specified Scheduler .
|
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.
|
@NonNull Flowable<Flowable<T>> |
Flowable.window(long count) |
Returns a Flowable that emits windows of items it collects from the current Flowable .
|
@NonNull Flowable<Flowable<T>> |
Flowable.window(long count,
long skip) |
Returns a Flowable that emits windows of items it collects from the current Flowable .
|
@NonNull Flowable<Flowable<T>> |
Flowable.window(long count,
long skip,
int bufferSize) |
Returns a Flowable that emits windows of items it collects from the current Flowable .
|
@NonNull Flowable<Flowable<T>> |
Flowable.window(long timespan,
long timeskip,
@NonNull java.util.concurrent.TimeUnit unit) |
Returns a Flowable that emits windows of items it collects from the current Flowable .
|
@NonNull Flowable<Flowable<T>> |
Flowable.window(long timespan,
long timeskip,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler) |
Returns a Flowable that emits windows of items it collects from the current Flowable .
|
@NonNull Flowable<Flowable<T>> |
Flowable.window(long timespan,
long timeskip,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
int bufferSize) |
Returns a Flowable that emits windows of items it collects from the current Flowable .
|
@NonNull Flowable<Flowable<T>> |
Flowable.window(long timespan,
@NonNull java.util.concurrent.TimeUnit unit) |
Returns a Flowable that emits windows of items it collects from the current Flowable .
|
@NonNull Flowable<Flowable<T>> |
Flowable.window(long timespan,
@NonNull java.util.concurrent.TimeUnit unit,
long count) |
Returns a Flowable that emits windows of items it collects from the current Flowable .
|
@NonNull Flowable<Flowable<T>> |
Flowable.window(long timespan,
@NonNull java.util.concurrent.TimeUnit unit,
long count,
boolean restart) |
Returns a Flowable that emits windows of items it collects from the current Flowable .
|
@NonNull Flowable<Flowable<T>> |
Flowable.window(long timespan,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler) |
Returns a Flowable that emits windows of items it collects from the current Flowable .
|
@NonNull Flowable<Flowable<T>> |
Flowable.window(long timespan,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
long count) |
Returns a Flowable that emits windows of items it collects from the current Flowable .
|
@NonNull Flowable<Flowable<T>> |
Flowable.window(long timespan,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
long count,
boolean restart) |
Returns a Flowable that emits windows of items it collects from the current Flowable .
|
@NonNull Flowable<Flowable<T>> |
Flowable.window(long timespan,
@NonNull java.util.concurrent.TimeUnit unit,
@NonNull Scheduler scheduler,
long count,
boolean restart,
int bufferSize) |
Returns a Flowable that emits windows of items it collects from the current Flowable .
|
<@NonNull B> @NonNull Flowable<Flowable<T>> |
Flowable.window(@NonNull org.reactivestreams.Publisher<@NonNull B> boundaryIndicator) |
Returns a Flowable that emits non-overlapping windows of items it collects from the current Flowable
where the boundary of each window is determined by the items emitted from a specified boundary-governing
Publisher .
|
<@NonNull B> @NonNull Flowable<Flowable<T>> |
Flowable.window(@NonNull org.reactivestreams.Publisher<@NonNull B> boundaryIndicator,
int bufferSize) |
Returns a Flowable that emits non-overlapping windows of items it collects from the current Flowable
where the boundary of each window is determined by the items emitted from a specified boundary-governing
Publisher .
|
<@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 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 U,@NonNull R> @NonNull Flowable<R> |
Flowable.withLatestFrom(@NonNull org.reactivestreams.Publisher<? extends @NonNull U> other,
@NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull R> combiner) |
Merges the specified Publisher into the current Flowable sequence by using the resultSelector
function only when the current Flowable (this instance) emits an 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 T1,@NonNull T2,@NonNull R> @NonNull Flowable<R> |
Flowable.withLatestFrom(@NonNull org.reactivestreams.Publisher<@NonNull T1> source1,
@NonNull org.reactivestreams.Publisher<@NonNull T2> source2,
@NonNull Function3<? super @NonNull T,? super @NonNull T1,? super @NonNull T2,@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 T1,@NonNull T2,@NonNull T3,@NonNull R> @NonNull Flowable<R> |
Flowable.withLatestFrom(@NonNull org.reactivestreams.Publisher<@NonNull T1> source1,
@NonNull org.reactivestreams.Publisher<@NonNull T2> source2,
@NonNull org.reactivestreams.Publisher<@NonNull T3> source3,
@NonNull Function4<? super @NonNull T,? super @NonNull T1,? super @NonNull T2,? super @NonNull T3,@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 T1,@NonNull T2,@NonNull T3,@NonNull T4,@NonNull R> @NonNull Flowable<R> |
Flowable.withLatestFrom(@NonNull org.reactivestreams.Publisher<@NonNull T1> source1,
@NonNull org.reactivestreams.Publisher<@NonNull T2> source2,
@NonNull org.reactivestreams.Publisher<@NonNull T3> source3,
@NonNull org.reactivestreams.Publisher<@NonNull T4> source4,
@NonNull Function5<? super @NonNull T,? super @NonNull T1,? super @NonNull T2,? super @NonNull T3,? super @NonNull T4,@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.
|
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 T1,@NonNull T2,@NonNull R> @NonNull Flowable<R> |
Flowable.zip(@NonNull org.reactivestreams.Publisher<? extends @NonNull T1> source1,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T2> source2,
@NonNull BiFunction<? super @NonNull T1,? super @NonNull T2,? extends @NonNull R> zipper) |
Returns a Flowable that emits the results of a specified combiner function applied to combinations of
two items emitted, in sequence, by two other Publisher s.
|
static <@NonNull T1,@NonNull T2,@NonNull R> @NonNull Flowable<R> |
Flowable.zip(@NonNull org.reactivestreams.Publisher<? extends @NonNull T1> source1,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T2> source2,
@NonNull BiFunction<? super @NonNull T1,? super @NonNull T2,? extends @NonNull R> zipper,
boolean delayError) |
Returns a Flowable that emits the results of a specified combiner function applied to combinations of
two items emitted, in sequence, by two other Publisher s.
|
static <@NonNull T1,@NonNull T2,@NonNull R> @NonNull Flowable<R> |
Flowable.zip(@NonNull org.reactivestreams.Publisher<? extends @NonNull T1> source1,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T2> source2,
@NonNull BiFunction<? super @NonNull T1,? super @NonNull T2,? extends @NonNull R> zipper,
boolean delayError,
int bufferSize) |
Returns a Flowable that emits the results of a specified combiner function applied to combinations of
two items emitted, in sequence, by two other Publisher s.
|
static <@NonNull T1,@NonNull T2,@NonNull T3,@NonNull R> @NonNull Flowable<R> |
Flowable.zip(@NonNull org.reactivestreams.Publisher<? extends @NonNull T1> source1,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T2> source2,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T3> source3,
@NonNull Function3<? super @NonNull T1,? super @NonNull T2,? super @NonNull T3,? extends @NonNull R> zipper) |
Returns a Flowable that emits the results of a specified combiner function applied to combinations of
three items emitted, in sequence, by three other Publisher s.
|
static <@NonNull T1,@NonNull T2,@NonNull T3,@NonNull T4,@NonNull R> @NonNull Flowable<R> |
Flowable.zip(@NonNull org.reactivestreams.Publisher<? extends @NonNull T1> source1,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T2> source2,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T3> source3,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T4> source4,
@NonNull Function4<? super @NonNull T1,? super @NonNull T2,? super @NonNull T3,? super @NonNull T4,? extends @NonNull R> zipper) |
Returns a Flowable that emits the results of a specified combiner function applied to combinations of
four items emitted, in sequence, by four other Publisher s.
|
static <@NonNull T1,@NonNull T2,@NonNull T3,@NonNull T4,@NonNull T5,@NonNull R> @NonNull Flowable<R> |
Flowable.zip(@NonNull org.reactivestreams.Publisher<? extends @NonNull T1> source1,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T2> source2,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T3> source3,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T4> source4,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T5> source5,
@NonNull Function5<? super @NonNull T1,? super @NonNull T2,? super @NonNull T3,? super @NonNull T4,? super @NonNull T5,? extends @NonNull R> zipper) |
Returns a Flowable that emits the results of a specified combiner function applied to combinations of
five items emitted, in sequence, by five other Publisher s.
|
static <@NonNull T1,@NonNull T2,@NonNull T3,@NonNull T4,@NonNull T5,@NonNull T6,@NonNull R> @NonNull Flowable<R> |
Flowable.zip(@NonNull org.reactivestreams.Publisher<? extends @NonNull T1> source1,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T2> source2,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T3> source3,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T4> source4,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T5> source5,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T6> source6,
@NonNull Function6<? super @NonNull T1,? super @NonNull T2,? super @NonNull T3,? super @NonNull T4,? super @NonNull T5,? super @NonNull T6,? extends @NonNull R> zipper) |
Returns a Flowable that emits the results of a specified combiner function applied to combinations of
six items emitted, in sequence, by six other Publisher s.
|
static <@NonNull T1,@NonNull T2,@NonNull T3,@NonNull T4,@NonNull T5,@NonNull T6,@NonNull T7,@NonNull R> @NonNull Flowable<R> |
Flowable.zip(@NonNull org.reactivestreams.Publisher<? extends @NonNull T1> source1,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T2> source2,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T3> source3,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T4> source4,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T5> source5,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T6> source6,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T7> source7,
@NonNull Function7<? super @NonNull T1,? super @NonNull T2,? super @NonNull T3,? super @NonNull T4,? super @NonNull T5,? super @NonNull T6,? super @NonNull T7,? extends @NonNull R> zipper) |
Returns a Flowable that emits the results of a specified combiner function applied to combinations of
seven items emitted, in sequence, by seven other Publisher s.
|
static <@NonNull T1,@NonNull T2,@NonNull T3,@NonNull T4,@NonNull T5,@NonNull T6,@NonNull T7,@NonNull T8,@NonNull R> @NonNull Flowable<R> |
Flowable.zip(@NonNull org.reactivestreams.Publisher<? extends @NonNull T1> source1,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T2> source2,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T3> source3,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T4> source4,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T5> source5,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T6> source6,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T7> source7,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T8> source8,
@NonNull Function8<? super @NonNull T1,? super @NonNull T2,? super @NonNull T3,? super @NonNull T4,? super @NonNull T5,? super @NonNull T6,? super @NonNull T7,? super @NonNull T8,? extends @NonNull R> zipper) |
Returns a Flowable that emits the results of a specified combiner function applied to combinations of
eight items emitted, in sequence, by eight other Publisher s.
|
static <@NonNull T1,@NonNull T2,@NonNull T3,@NonNull T4,@NonNull T5,@NonNull T6,@NonNull T7,@NonNull T8,@NonNull T9,@NonNull R> @NonNull Flowable<R> |
Flowable.zip(@NonNull org.reactivestreams.Publisher<? extends @NonNull T1> source1,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T2> source2,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T3> source3,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T4> source4,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T5> source5,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T6> source6,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T7> source7,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T8> source8,
@NonNull org.reactivestreams.Publisher<? extends @NonNull T9> source9,
@NonNull Function9<? super @NonNull T1,? super @NonNull T2,? super @NonNull T3,? super @NonNull T4,? super @NonNull T5,? super @NonNull T6,? super @NonNull T7,? super @NonNull T8,? super @NonNull T9,? extends @NonNull R> zipper) |
Returns a Flowable that emits the results of a specified combiner function applied to combinations of
nine items emitted, in sequence, by nine other Publisher s.
|
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.
|
<@NonNull U,@NonNull R> @NonNull Flowable<R> |
Flowable.zipWith(@NonNull java.lang.Iterable<@NonNull U> other,
@NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull R> zipper) |
Returns a Flowable that emits items that are the result of applying a specified function to pairs of
values, one each from the current Flowable and a specified Iterable sequence.
|
<@NonNull U,@NonNull R> @NonNull Flowable<R> |
Flowable.zipWith(@NonNull org.reactivestreams.Publisher<? extends @NonNull U> other,
@NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull R> zipper) |
Returns a Flowable that emits items that are the result of applying a specified function to pairs of
values, one each from the current Flowable and another specified Publisher .
|
<@NonNull U,@NonNull R> @NonNull Flowable<R> |
Flowable.zipWith(@NonNull org.reactivestreams.Publisher<? extends @NonNull U> other,
@NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull R> zipper,
boolean delayError) |
Returns a Flowable that emits items that are the result of applying a specified function to pairs of
values, one each from the current Flowable and another specified Publisher .
|
<@NonNull U,@NonNull R> @NonNull Flowable<R> |
Flowable.zipWith(@NonNull org.reactivestreams.Publisher<? extends @NonNull U> other,
@NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull R> zipper,
boolean delayError,
int bufferSize) |
Returns a Flowable that emits items that are the result of applying a specified function to pairs of
values, one each from the current Flowable and another specified Publisher .
|