android - RxJava 如何正确地重新订阅 onError

Question

所以我正在开发一个 android 项目，目前，我正在使用 RxJava 从 WS 获取数据并在准备好后立即显示它。我正在使用以下方法，我不确定这是最好的方法。

• 如果 onError 被调用，重新订阅

      private void getGeneralLiveData(Observable<CurrentGameInfo> obsCurrentGameInfoBySummonerId) {
      /**
       * Get General Live Data
       */
      subscriptions.add(
              obsCurrentGameInfoBySummonerId
                  .doOnSubscribe(() -> currentGameGlobalInfo.enableProgressBar(true))
                  .doOnUnsubscribe(() -> currentGameGlobalInfo.enableProgressBar(false))
                  .subscribe(onNext -> ... ,onError-> {
                          getGeneralLiveData(obsCurrentGameInfoBySummonerId);
                   }
  );
  

这目前正在运行，我得到了我想要的结果。但我不确定这是最好的方法。所以我有两个问题:

• 是否有任何适当的方法来完成同样的事情？

Answer 1

使用retry运营商，看到这个答案:

How to terminate an Observable?