Rx-Java集中式错误处理

Question

像这样的东西

 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

我认为您想用单个可观察到的实现太多的tihngs。

您可以使用一些HttpErrorHandler，它将具有方法

boolean fix(Exception e) 

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