android – Retrofit RxJava – 如果我使用了Disposable.dispose(),那么当片段恢复时不会发光

我有一个片段A使用Retrofit来调用onCreateView中的API.
结果将用于显示对象列表.

片段A还有一个导航到片段B的按钮,通过提交FragmentTransaction并替换自身. (片段A onDestroyView触发)

一切都运行良好,但当我从Fragment B回到Fragment A(片段A onCreateView触发)时,API不会被调用.

只有在onDestroyView中调用Disposable.dispose()时才会发生这种情况,这是为了防止内存泄漏.

我所期待的

由于每次onCreateView被触发时都会创建新的Observable,因此它们应该与之前处置的Disposables无关.因此将再次调用API并触发回调.应刷新对象列表.

我观察到了什么

onCreateView被触发,也会触发告诉Retrofit调用API的行.但是没有一个回调(包括.map())被触发.由于我也记录了网络流量,我很确定实际上没有进行任何网络通信.看起来RxJava或Retrofit决定停止流.

问题

当然,如果我不使用Disposable.dispose(),这可以避免.但我确实想防止内存泄漏.
这样做的正确方法是什么?

我的代码(简体)

片段A:

public class BeansFragment extends BaseFragment {

   ...

    @Nullable
    @Override
    public View onCreateView(LayoutInflater inflater, @Nullable ViewGroup container, @Nullable Bundle savedInstanceState) {
        ...
        retrofit.getSomeBeans()
                .subscribeOn(Schedulers.io())
                .unsubscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new APIResponseObserver<List<Beans>>(this) {
                    @Override
                    public void onNext(List<Beans> beans) {
                        if (getContext() == null) return;
                        setupBeansList(beans);
                    }
                });
        ...
    }

    ...
}

BaseFragment:

public abstract class BaseFragment extends Fragment {

    private CompositeDisposable compositeDisposable = new CompositeDisposable();

    ...

    @Override
    public void onDestroyView() {
        compositeDisposable.dispose();
        super.onDestroyView();
    }
}

最重要的是,APIResponseObserver负责添加一次性用品:

public abstract class APIResponseObserver<T> implements io.reactivex.Observer<T> {

    private BaseFragment fragment;

    public APIResponseObserver(BaseFragment fragment) {
        this.fragment = fragment;
    }

    @Override
    public void onSubscribe(Disposable d) {
        if (fragment != null) fragment.addToCompositeDisposable(d);
    }

    @Override
    public void one rror(Throwable e) {
        //...
    }

    @Override
    public void onComplete() {
        //...
    }
}

注意

我也试过使用RxLifecycle,但产生了相同的结果.

解决方法:

刚刚发现我应该使用Disposable.clear()而不是dispose(). dispose()使我无法再将Disposable添加到同一个CompositeDisposable中.

一个有趣的事实是,RxLifecycle产生了同样的问题.这是否意味着他们使用dispose()而不是clear()?

编辑@ 2018年4月20日

对于RxLifecycle,您可以参考this Github issue.

上一篇:android – Retrofit java.net.SocketTimeoutException


下一篇:android – NetworkOnMainThreadException with retrofit-beta2和rxjava