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 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 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 Function3<? super @NonNull T1,? super @NonNull T2,? super @NonNull T3,? extends @NonNull R> combiner) |
Combines three 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 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 Publishers via a function to produce the output item.
|
<@NonNull T1,@NonNull T2,@NonNull R> @NonNull Observable<R> |
Observable.withLatestFrom(@NonNull ObservableSource<@NonNull T1> source1,
@NonNull ObservableSource<@NonNull T2> source2,
@NonNull Function3<? super @NonNull T,? super @NonNull T1,? super @NonNull T2,@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 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 Publishers.
|
static <@NonNull T1,@NonNull T2,@NonNull T3,@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 Function3<? super @NonNull T1,? super @NonNull T2,? super @NonNull T3,? extends @NonNull R> zipper) |
Returns a Maybe that emits the results of a specified combiner function applied to combinations of
three items emitted, in sequence, by three other MaybeSources.
|
static <@NonNull T1,@NonNull T2,@NonNull T3,@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 Function3<? super @NonNull T1,? super @NonNull T2,? super @NonNull T3,? extends @NonNull R> zipper) |
Returns an Observable that emits the results of a specified combiner function applied to combinations of
three items emitted, in sequence, by three other ObservableSources.
|
static <@NonNull T1,@NonNull T2,@NonNull T3,@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 Function3<? super @NonNull T1,? super @NonNull T2,? super @NonNull T3,? extends @NonNull R> zipper) |
Returns a Single that emits the results of a specified combiner function applied to three items emitted
by three other SingleSources.
|