Rx-Java 集中式错误处理

Question

我使用 Retrofit 作为 Rx-Java 的网络库。我想对大多数请求进行一些集中式错误检查并处理错误，或者如果我无法处理它，则将其传递给订阅者的onError()。我怎么能这样做？

类似的东西

 projectListObservable
    .subscribeOn(Schedulers.newThread())
    .timeout(App.NETWORK_TIMEOUT_SEC, TimeUnit.SECONDS)
    .retry(App.NETWORK_RETRY_COUNT)
    .onError(e -> {
     if (e instanseOf HttpError && ((HttpError)e).getCode == 403){
        App.getInstance.getNetworkManager.reAuth();
     } else {
        throw(e);
     }})
   .observeOn(AndroidSchedulers.mainThread())
   .subscribe(new ProjectListSubscriber());

另外，在这种情况下我应该停止重试，但如果是网络问题，请继续重试 (instanceof IOException)。

Answer 1

我认为你想用一个 observable 实现太多的 tihng。

你可以有一些HttpErrorHandler，它会有方法

boolean fix(Exception e) 

如果错误处理程序修复了异常（更新令牌等），则返回 true。您可以针对不同情况使用不同的错误处理程序，也可以针对所有情况使用不同的错误处理程序。 TokenErrorHandler RetryErrorHandler 然后做一个链。

如果所有错误处理函数都返回 false，则将此异常向上层抛出