在继续之前等待两个观测值完成？

Question

我有一个加载页面，我想在其中对不相关的信息执行两个网络请求（rxjava）。在这两个请求完成之前，我不想进入下一页，即使其中一个或两个都失败了。

>

使用zip将请求绑定在一起。有没有办法不必被迫使用双函数，也不必返回null？

请求A和B有一个。doOnNext和。多恩。如果其中一个返回错误，zip observable是否继续？zip订阅服务器是否也会返回错误？

这是最好的方法吗？

private Disposable retrieveBothThings() {
return Observable.zip(getThingA(), getThingB(),
                    (A, B) -> {
                        onAllCallsComplete();
                        return null;
                    })
                    .subscribeOn(Schedulers.io())
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribe(o -> {}, Logger::e);
}
    
    

private Observable<...> getThingA() {
            return SessionManager.getInstance().getApi()
                    .getA()
                    .subscribeOn(Schedulers.io())
                    .observeOn(AndroidSchedulers.mainThread())
                    .doOnNext(this::onACompleted)
                    .doOnError(this::onAFailed);
}

private Observable<...> getThingB() {
        return SessionManager.getInstance().getApi()
                .getB()
                .subscribeOn(Schedulers.io())
              .observeOn(AndroidSchedulers.mainThread()).toObservable()
                .doOnNext(this::onBSuccess)
                .doOnError(this::onBFailure);
}
    
private void onBSuccess(...) {
    ...        
}
    
private void onBFailure(final Throwable throwable) {
    Logger.e(throwable);
}

private void onACompleted(...) {
    ...        
}
    
private void onAFailed(final Throwable throwable) {
    Logger.e(throwable);
}

Answer 1

可以使用merge（）操作符组合两个观察值。您可以使用onErrorResumeNext（）将错误转换为onComplete（）。

Completable.merge(
  observable1
    .doOnNext(this::onACompleted)
    .doOnError(this::onAFailed)
    .onErrorResumeNext( Completable.complete() )
    .toCompletable(),
  observable2
    .doOnNext(this::onBCompleted)
    .doOnError(this::onBFailed)
    .onErrorResumeNext( Completable.complete() ),
    .toCompletable() )
.subscribe( ignore -> {}, 
            error -> {},
            () -> { processCompletion(); } );