Android/RxJava，防止同类型的多个订阅

Question

早上好，我最近开始玩 RxJava，但遇到了一个问题。

我在 ViewPager 中有一个 Fragment，它在 onViewCreated() 上启动一个 HTTP 请求（由 Retrofit 和 RxJava 处理）以检索字符串列表。 它的实现方式是创建订阅并将其添加到 CompositeSubscription 对象

这里是代码

final Subscription subscription = MyManager.getService().getListStringsFromWeb()
            .subscribeOn(Schedulers.newThread())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Observer<List<String>() {
                @Override
                public void onCompleted() {
                    // DO NOTHING
                }

                @Override
                public void onError(Throwable e) {
                    // DO SOMETHING
                }

                @Override
                public void onNext(List<String> result) {
                    returnResultToView(result);
                }
            });
addSubscription(subscription);

在 onViewCreated() 的 Fragment 中，我检查结果是否存在，如果没有我们调用上面的方法，如果有我们很高兴。

问题是当我旋转设备时，“第一个”订阅尚未返回，因此片段不会记住数据，它会启动另一个搜索，如果我继续旋转我继续添加订阅

我想知道是否有办法保留第一个订阅，当它的结果到达时，只需将其返回给 Fragment 并忽略所有其他订阅

一步一步想要的行为：

• 启动片段和请求
• 屏幕显示加载图像和启动订阅/请求的背景
• 自第一个请求仍处于挂起状态以来，多次屏幕旋转保持加载图像
• 第一次调用的结果返回后，将其返回到片段，从而隐藏加载图像并显示结果

非常感谢

Answer 1

关于 Fragments 和 RxJava 的不幸之处在于，您必须以某种方式保持可观察性。一种方法是使它们静态到Fragment，这样您只创建一次，然后在onStart()/onStop() 中订阅/取消订阅，或者您决定。

如果您不喜欢制作静态变量，另一种方法是使用保留的片段来处理数据。数据的视图Fragment 然后可以将自己“绑定”到数据片段。这种方法的优点是数据很容易被 Activity 的所有组件访问，它从视图中抽象出数据以便于测试，并且比生命周期组件更长寿。

因此，对于保留的片段，您可以执行以下操作：

public class DataFragment extends Fragment {

   private Observable<List<String> stringObs;

   @Override
   public void onAttach(Context ctx) {
      super.onAttach(ctx);
      setRetainInstance(true);
   }

   @Override
   public void onCreateView(LayoutInflater inflater, ViewGroup group, Bundle savedInsatnceState) {
      return null; // no view, no problem.
   }

   public Observable<List<String>> getStrings() {
     if (stringsObs == null) {
         stringsObs = MyManager.getService()
            .getListStringsFromWeb()
            .cache()
            .subscribeOn(Schedulers.newThread())
            .observeOn(AndroidSchedulers.mainThread());
     }
     return stringsObs;
   }
}

像这样将DataFragment 添加到 FragmentManager：

FragmentManager fm = getFragmentManager();
DataFragment df = fm.findFragmentByTag("DataFragment");
if (df == null) {
   // Only add the retained fragment if it doesn't exist.  Otherwise, use the old one.
   fm.beginTransaction()
   .add(new DataFragment(), "DataFragment")
   .commit();
}

然后你可以像这样在 ViewFragment 上订阅它：

public class ViewFragment extends Fragment {

   private Subscription s;

   @Override
   public void onStart() {
     super.onStart();
     DataFragment dataFragment = (DataFragment) getFragmentManager().findFragmentByTag("DataFragment");
     s = dataFragment.getStrings()
            .subscribe(new Observer<List<String>() {
              // Do things
            });
   }

   @Override
   public void onStop() {
      super.onStop();
      s.unsubscribe();
   }
}

现在，您的 ViewFragment 可以随心所欲地消失和重新出现，而不会妨碍下载。以您需要的方式操作 Observable 也更容易。