rx-java2 - 我们如何在 retryWhen() 停止重试后获得 Throwable？

  private String stringResult=null;
  private Throwable throwableResult=null;

  @Test
  public void whereIsTheThrowable() {
    Observable.just("foo")
      .map(this::justBlowUp)
      .retryWhen(errors -> errors.zipWith(Observable.range(1, 3), (n, i) -> i))
      .subscribe(s -> stringResult=s, throwable -> throwableResult=throwable);

    assertNull(stringResult);
    assertNotNull(throwableResult);
  }

  private String justBlowUp(String s) {
    throw new RuntimeException();
  }

该测试在 RxJava 2.1.7 中失败。 retryWhen() 似乎消耗了 Throwable ，即使它不再重试。 subscribe() lambda 没有得到任何 Throwable 。虽然这个测试很愚蠢(justBlowUp() 只是爆炸了)，但你可以想象一个 Observable 链，其中工作通常会成功，偶尔会失败，很少会连续失败四次。但是，在这种情况下，将 Throwable 用于日志记录会很有用。
retryUntil() 确实允许 subscribe() 获得最终的 Throwable ...但是在 retryUntil() 中，我们根本没有 Throwable 并且无法对其做出决定(例如，如果它似乎是 Internet 连接错误，则重试 N 次，但快速失败其他一切)。 retryWhen() 似乎是更强大的选项，但是在 Throwable 停止重试后，我们如何获得最终的 retryWhen() ？

我可以使用一个字段来保存 Throwable ，设置在 retryWhen() 逻辑中，但感觉应该有一个更惯用的解决方案。

最佳答案

retryWhen 将处理程序的完成视为正常完成的指示器，因此，处理程序应在重试选项用尽后失败:

Observable.just("foo")
.map(this::justBlowUp)
.retryWhen(errors -> errors.flatMap(new Function<Throwable, Observable<Integer>>() {
    int count;
    @Override
    public Observable<Integer> apply(Throwable error) {
        if (count++ < 3) {
            return Observable.just(count);
        }
        return Observable.error(error);
    }
}))
.test()
.assertFailure(RuntimeException.class);

关于rx-java2 - 我们如何在 retryWhen() 停止重试后获得 Throwable？，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/49111878/