RxJava retryWhen 和 onError

RxJava retryWhen and onError

我开始使用rxJava进行开发,遇到以下情况:

我有一个 observable,我希望有一个订阅者来处理错误 onError,而另一个订阅者来处理 retryWhen

重试时吞了错误,如何避免吞错误?

你可以像这样把 doOnError/doOnEach 放在 retryWhen 之前:

    o.doOnError(t -> {
      // do something 
    }).retryWhen(o -> {
      // do something
    });