如何在RxJava2链式调用中优先抛出首个可捕获错误？

我完全懂你的痛点：现在用onErrorResumeNext兜底调用本地API时，一旦两者都失败，下游Presenter拿到的是本地的错误，但你需要优先展示远程API的错误。结合MVP架构的Model层场景，给你两个实用的解决方案：

方案一：保存远程错误，本地失败时抛出它 #

你可以在Model层维护一个线程安全的变量来存储远程API的错误，当本地API也失败时，直接抛出这个保存的远程错误：

// Model层成员变量，用AtomicReference保证多线程场景下的安全
private AtomicReference<Throwable> remoteErrorRef = new AtomicReference<>();

public Observable<Data> fetchData() {
    return remoteSource.fetchData()
            // 捕获远程错误并存储
            .doOnError(remoteError -> remoteErrorRef.set(remoteError))
            // 远程失败时触发本地API调用
            .onErrorResumeNext(e -> localSource.fetchData()
                    // 本地也失败时，优先抛出远程错误；极端情况无远程错误才抛本地错误
                    .onErrorResumeNext(localError -> Observable.error(
                            remoteErrorRef.get() != null ? remoteErrorRef.get() : localError
                    )))
            .doOnSuccess(this::saveData);
}

这个思路很直接：先把远程错误存起来，当本地也掉链子的时候，就把之前存的远程错误抛给Presenter，这样Presenter拿到的就是你想要的远程错误了。AtomicReference是为了避免RxJava多线程调度时的变量竞争问题。

方案二：用flatMap嵌套处理错误流 #

如果不想维护额外的成员变量，也可以用flatMap嵌套处理，把远程错误直接传递到本地API的错误处理逻辑里：

public Observable<Data> fetchData() {
    return remoteSource.fetchData()
            .flatMap(data -> {
                saveData(data);
                return Observable.just(data);
            })
            // 远程失败时，带着远程错误进入本地API调用流程
            .onErrorResumeNext(remoteError -> localSource.fetchData()
                    .flatMap(data -> {
                        saveData(data);
                        return Observable.just(data);
                    })
                    // 本地也失败，直接抛出之前的远程错误
                    .onErrorResumeNext(localError -> Observable.error(remoteError))
            );
}

这个方案的优势是逻辑更连贯：远程成功就保存返回；远程失败后，把错误带入下一个流，当本地也失败时，直接抛出这个远程错误，不需要额外存储变量，代码更紧凑。

额外提醒 #

• 不管用哪个方案，都要确保错误处理的线程一致性，RxJava的调度器如果切换了线程，AtomicReference能帮你避免线程安全问题；
• 远程API的错误信息通常更有指导意义（比如提示用户检查网络），这样的处理能让用户得到更准确的反馈，比展示本地错误更合理。

内容的提问来源于stack exchange，提问作者hehe