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 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 ObservableSource s by emitting an item that aggregates the latest values of each of the
ObservableSource s each time an item is received from any of the ObservableSource s, where this
aggregation is defined by a specified function.
|
<@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.
|
<@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 ObservableSource s 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 Publisher s.
|
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 MaybeSource s.
|
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 ObservableSource s.
|
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 SingleSource s.
|