2+ RxJava retryWhen

Question

我正在使用Retrofit 2和RxJava 2适配器。

每当服务器返回401未经授权时，我刷新令牌并重试请求：

apiCall.retryWhen(es -> es
    .flatMap(e -> {
        if (isUnauthorizedException(e)) {
            return refreshToken();
        }

        return Flowable.<User>error(e);
    }));

其中refreshToken是一个简单的更新调用：

public Flowable<User> refreshToken() {
    return retrofitService.login(userCredentials);
}

现在，我想限制这种刷新的次数。但是，简单地添加take(1)不起作用，因为然后retryWhen会在onNext之后立即接收onCompleted，并在重试请求之前取消请求。

当然，我可以做take(2)以达到预期的效果，但这似乎是一个黑客。

使用Rx操作符来实现它的最优雅的方法是什么？还有一个带有“断言”逻辑的操作符(以消除平面映射中的if )吗？

此外，我知道我可以使用OkHttp拦截器实现同样的目标，但我对RxJava解决方案很感兴趣。

Answer 1

文档中有一个很好的例子。

这个重试3次，每次增加它等待的秒数。

ObservableSource.create((Observer<? super String> s) -> {

  System.out.println("subscribing");
  s.onError(new RuntimeException("always fails"));

}).retryWhen(attempts -> {

  return attempts.zipWith(ObservableSource.range(1, 3), 
    (n, i) -> i).flatMap(i -> {

    System.out.println("delay retry by " + i + " second(s)");
    return ObservableSource.timer(i, TimeUnit.SECONDS);

  });
}).blockingForEach(System.out::println);

产出如下：

• 订阅
• 延迟1秒重试
• 订阅延迟重试2秒
• 订阅延迟重试3秒
• 订阅

您可以根据需要修改此示例。