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 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 T6,@NonNull T7,@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 ObservableSource<? extends @NonNull T6> source6,
@NonNull ObservableSource<? 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 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.
|
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 Publishers.
|
static <@NonNull T1,@NonNull T2,@NonNull T3,@NonNull T4,@NonNull T5,@NonNull T6,@NonNull T7,@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 MaybeSource<? extends @NonNull T6> source6,
@NonNull MaybeSource<? 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 Maybe that emits the results of a specified combiner function applied to combinations of
seven items emitted, in sequence, by seven other MaybeSources.
|
static <@NonNull T1,@NonNull T2,@NonNull T3,@NonNull T4,@NonNull T5,@NonNull T6,@NonNull T7,@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 ObservableSource<? extends @NonNull T6> source6,
@NonNull ObservableSource<? 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 an Observable that emits the results of a specified combiner function applied to combinations of
seven items emitted, in sequence, by seven other ObservableSources.
|
static <@NonNull T1,@NonNull T2,@NonNull T3,@NonNull T4,@NonNull T5,@NonNull T6,@NonNull T7,@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 SingleSource<? extends @NonNull T6> source6,
@NonNull SingleSource<? 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 Single that emits the results of a specified combiner function applied to seven items
emitted by seven other SingleSources.
|