Skip to content Skip to sidebar Skip to footer

Rxjava/android: Combine Result Of Two Dependent Observables

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"