Android：使用 RxJava2 订阅 Apollo

Question

我在 Apollo 中使用 Rxjava2 订阅，如下所示

Rx2Apollo.from(someApolloCall)
.observeOn(schedulerProvider.io())
.subscribeOn(schedulerProvider.ui())
.subscribe({

  // on success

}, {
  // on failure
})

网络正常时一切正常，但是当失去连接时，订阅失败并且不再重新连接？

在类似情况下我应该如何重新连接， 我一直在尝试使用 rxjava 操作retryWhen{} 但徒劳无功！

提前致谢。

Answer 1

retryWhen回复onError重新订阅。

以下代码重试次数有限（3 次，每次尝试延迟 5 次）

response.retryWhen(errors ->
  errors
    .zipWith(Observable.range(1, 3), (n, i) -> i)
    .flatMap(retryCount -> Observable.timer((long) Math.pow(5, retryCount), TimeUnit.SECONDS))
);

另外，请确保您订阅了 subscribeOn.Schedulers.io() 和 observeOn(AndroidSchedulers.mainThread() 在 Android 主线程上执行发射（操作）。