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 Publishers by emitting an item that aggregates the latest values of each of the
source Publishers each time an item is received from any of the source Publishers, where this
aggregation is defined by a specified function.
|
static <@NonNull T1,@NonNull T2,@NonNull T3,@NonNull T4,@NonNull T5,@NonNull R> @NonNull Observable<R> |
Observable.combineLatest(@NonNull ObservableSource<? extends @NonNull T1> source1,
@NonNull ObservableSource<? extends @NonNull T2> source2,
@NonNull ObservableSource<? extends @NonNull T3> source3,
@NonNull ObservableSource<? extends @NonNull T4> source4,
@NonNull ObservableSource<? 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 ObservableSources by emitting an item that aggregates the latest values of each of the
ObservableSources each time an item is received from any of the ObservableSources, where this
aggregation is defined by a specified function.
|
<@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 Publishers via a function to produce the output item.
|
<@NonNull T1,@NonNull T2,@NonNull T3,@NonNull T4,@NonNull R> @NonNull Observable<R> |
Observable.withLatestFrom(@NonNull ObservableSource<@NonNull T1> source1,
@NonNull ObservableSource<@NonNull T2> source2,
@NonNull ObservableSource<@NonNull T3> source3,
@NonNull ObservableSource<@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 Observable with the latest emissions from the
other ObservableSources via a function to produce the output item.
|
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 Publishers.
|
static <@NonNull T1,@NonNull T2,@NonNull T3,@NonNull T4,@NonNull T5,@NonNull R> @NonNull Maybe<R> |
Maybe.zip(@NonNull MaybeSource<? extends @NonNull T1> source1,
@NonNull MaybeSource<? extends @NonNull T2> source2,
@NonNull MaybeSource<? extends @NonNull T3> source3,
@NonNull MaybeSource<? extends @NonNull T4> source4,
@NonNull MaybeSource<? 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 Maybe that emits the results of a specified combiner function applied to combinations of
five items emitted, in sequence, by five other MaybeSources.
|
static <@NonNull T1,@NonNull T2,@NonNull T3,@NonNull T4,@NonNull T5,@NonNull R> @NonNull Observable<R> |
Observable.zip(@NonNull ObservableSource<? extends @NonNull T1> source1,
@NonNull ObservableSource<? extends @NonNull T2> source2,
@NonNull ObservableSource<? extends @NonNull T3> source3,
@NonNull ObservableSource<? extends @NonNull T4> source4,
@NonNull ObservableSource<? 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 an Observable that emits the results of a specified combiner function applied to combinations of
five items emitted, in sequence, by five other ObservableSources.
|
static <@NonNull T1,@NonNull T2,@NonNull T3,@NonNull T4,@NonNull T5,@NonNull R> @NonNull Single<R> |
Single.zip(@NonNull SingleSource<? extends @NonNull T1> source1,
@NonNull SingleSource<? extends @NonNull T2> source2,
@NonNull SingleSource<? extends @NonNull T3> source3,
@NonNull SingleSource<? extends @NonNull T4> source4,
@NonNull SingleSource<? 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 Single that emits the results of a specified combiner function applied to five items
emitted by five other SingleSources.
|