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 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 ObservableSource<? 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 ObservableSource s by emitting an item that aggregates the latest values of each of the
ObservableSource s each time an item is received from any of the ObservableSource s, where this
aggregation is defined by a specified function.
|
static <@NonNull 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 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 MaybeSource<? 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 Maybe that emits the results of a specified combiner function applied to combinations of
eight items emitted, in sequence, by eight other MaybeSource s.
|
static <@NonNull T1,@NonNull T2,@NonNull T3,@NonNull T4,@NonNull T5,@NonNull T6,@NonNull T7,@NonNull T8,@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 ObservableSource<? 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 an Observable that emits the results of a specified combiner function applied to combinations of
eight items emitted, in sequence, by eight other ObservableSource s.
|
static <@NonNull T1,@NonNull T2,@NonNull T3,@NonNull T4,@NonNull T5,@NonNull T6,@NonNull T7,@NonNull T8,@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 SingleSource<? 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 Single that emits the results of a specified combiner function applied to eight items
emitted by eight other SingleSource s.
|