Rxjava/android: Combine Result Of Two Dependent Observables
I have two Observables. Observable getAObservable() Returns Observable of A Observable getBObservable(A) Returns Observable of 'B'. Here Observable sh
Solution 1:
See flatMap
documentation. It has overloaded method, that apply zip function:
Observable<Pair<A, B>> abObservable = getAObservable()
.flatMap(
new Func1<A, Observable<? extends B>>() {
@Override
public Observable<? extends B> call(A a) {
return getBObservable(a);
}
},
new Func2<A, B, Pair<A, B>>() {
@Override
public Pair<A, B> call(A a1, B b1) {
return new Pair<>(a1, b1);
}
}
);
Post a Comment for "Rxjava/android: Combine Result Of Two Dependent Observables"