Выполнить 2 наблюдаемых последовательно и сразу получить результат — RxJava 2

У меня есть эта функция:

public static class CombinedResult<T, R> {
    T t;
    R r;

    public CombinedResult(T t, R r) {
        this.t = t;
        this.r = r;
    }

    public T getObject1() {
        return t;
    }

    public void setObject1(T t) {
        this.t = t;
    }

    public R getObject2() {
        return r;
    }

    public void setObject2(R r) {
        this.r = r;
    }

}

public static <A, B> Observable<CombinedResult<A, B>> combineObservablesParallel(Observable<A>
    return Observable.zip(observable1, observable2, new BiFunction<A, B, CombinedResult<A, B>>() {
        @Override
        public CombinedResult<A, B> apply(A a, B b) throws Exception {
            return new CombinedResult<>(a,b);
        }
    });
}

Он объединяет 2 observable и возвращает 1 Observable, который получит результат обоих observable в объект CombinedResult. Проблема здесь в том, что функция zip объединяет наблюдаемые на Parallel.

Я хочу что-то вроде zip, которое последовательно выполняет наблюдаемое и возвращает результат в BiFunction или что-то в этом роде.

какое может быть решение?


android rx-java2 rx-java
person MBH    schedule 28.02.2017    source источник
comment
Попробуйте Observable.concat()   -  person John O'Reilly    schedule 28.02.2017

Ответы (1)


arrow_upward
4
arrow_downward

Используйте оператор flatMap для observable1 в сочетании с операторами observable2 и zip:

RxJava 1:

return observable1
                .flatMap(new Func1<A, Observable<CombinedResult<A, B>>>() {
                    @Override
                    public Observable<CombinedResult<A, B>> call(A a) {
                        return Observable.just(a).zipWith(observable2, new Func2<A, B, CombinedResult<A, B>>() {
                            @Override
                            public CombinedResult<A, B> call(A a, B b) {
                                return new CombinedResult<>(a, b);
                            }
                        });
                    }
                });

RxJava 2:

return observable1.flatMap(new Function<A, ObservableSource<CombinedResult<A,B>>>() {
    @Override
    public ObservableSource<CombinedResult<A,B>> apply(A a) throws Exception {
        return Observable.just(a).zipWith(observable2, new BiFunction<A, B, CombinedResult<A, B>>() {
            @Override
            public CombinedResult<A, B> apply(A a, B b) throws Exception {
                return new CombinedResult<>(a,b);
            }
        });
    }
});

RxJava 2 Лямбда:

return observable1.flatMap(a -> Observable.just(a).zipWith(observable2, CombinedResult::new));
person R. Zagórski    schedule 28.02.2017
comment
Спасибо, я только что немного изменил код для RxJava 2. - person MBH; 28.02.2017