rx-java - 如果 retryWhen :s retries runs out 则捕获错误

Question

在 documentation for RetryWhen那里的例子是这样的:

Observable.create((Subscriber<? super String> s) -> {
  System.out.println("subscribing");
  s.onError(new RuntimeException("always fails"));
}).retryWhen(attempts -> {
  return attempts.zipWith(Observable.range(1, 3), (n, i) -> i).flatMap(i -> {
      System.out.println("delay retry by " + i + " second(s)");
      return Observable.timer(i, TimeUnit.SECONDS);
  });
}).toBlocking().forEach(System.out::println);

但是，如果重试用完，我该如何传播错误？

添加 .doOnError(System.out::println)后 retryWhen子句没有捕捉到错误。它甚至发出了吗？

添加 .doOnError(System.out::println)重试前何时显示 always fails对于所有重试。

Answer 1

retryWhen 的文档说它将 onError 通知传递给其订阅者并终止。所以你可以做这样的事情:

    final int ATTEMPTS = 3;

    Observable.create((Subscriber<? super String> s) -> {
        System.out.println("subscribing");
        s.onError(new RuntimeException("always fails"));
    }).retryWhen(attempts -> attempts
            .zipWith(Observable.range(1, ATTEMPTS), (n, i) ->
                    i < ATTEMPTS ?
                            Observable.timer(i, SECONDS) :
                            Observable.error(n))
            .flatMap(x -> x))
            .toBlocking()
            .forEach(System.out::println);