我有一个片段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.