从 RxJava2/RxAndroid PublishSubject 退订

Question

我正在尝试用 RxAndroid 替换 EventBus。

我希望可分页片段订阅/取消订阅事件源，这些片段的创建和丢弃速度相对较快，具体取决于用户滑动到新页面的速度。

在 EventBus 中，我能够添加一个修饰的回调方法（即@Subscribe(threadMode = ThreadMode.MAIN)）并在片段的 onStart/onStop 方法中注册/取消注册。

使用 RxJava2，我现在在一个类中创建一个 PublishSubject 对象

public static PublishSubject<List<Long>> m_psUpdatedDays = PublishSubject.create();
public static void publishUpdatedDays(List<Long> lDay) {
    m_psUpdatedDays.onNext(lDay);
}

并通过在 Fragment 的 onStart 方法中调用以下内容在另一个类中订阅此发布者：

m_psUpdatedDays.observeOn(AndroidSchedulers.mainThread()).subscribe(new Observer<List<Long>>() {
    @Override public void onSubscribe(Disposable d) {}
    @Override public void onNext(List<Long> longs) {
      ...
      Update Fragment UI here
      ...
    }
    @Override public void onError(Throwable e) {}
    @Override public void onComplete() {}
});

我的问题是，当 Fragment 的 onStop 方法被系统调用时，如何取消订阅这个新的 Observer？

我是否需要存储我在onSubscribe 中获得的Disposable 对象，然后在onStop 方法中对其调用.dispose()？

Answer 1

您可以使用CompositeDisposable 对象，该对象可以保存一次性物品列表，并且可以将它们全部一起处理。

在基本片段级别创建一个CompositeDisposable 实例，继续将您的一次性用品添加到其中。

    public abstract class BaseFragment extends Fragment {
        protected CompositeDisposable mCompositeDisposable = new CompositeDisposable();

        @Override
        public void onPause() {
            super.onPause();
            mCompositeDisposable.clear();
            //clear will clear all, but can accept new disposable.
            // You can call it on `onPause` or `orDestroyView` events.
        }

        @Override
        public void onDestroy() {
            super.onDestroy();
            mCompositeDisposable.dispose();
            //dispose will clear all and set isDisposed = true, so it will not accept any new disposable
        }
    }

在您的 Fragment 中，使用 subscribeWith 方法订阅 Observable，它会立即为您提供 disposable，并且您可以稍后在 onPause 或 onDestroy 事件中处置此一次性物品（无论​​您想要什么）

     public class MyFragment extends BaseFragment {


            @Override
            public void onStart() {
                super.onStart();
                Disposable disposable = m_psUpdatedDays.observeOn(AndroidSchedulers.mainThread())
                        .subscribeWith(new DisposableObserver<List<Long>>() { // Use `subscribeWith` instead of `subscribe`, which will give you back the disposable , which can be disposed later
                            @Override
                            public void onNext(List<Long> longs) {
                                // Update Fragment UI here
                            }

                            @Override
                            public void onError(Throwable e) {

                            }

                            @Override
                            public void onComplete() {

                            }
                        });
                mCompositeDisposable.add(disposable); // add the disposable to the disposable list
            }
        }