Android 之路 (12) - RxLifecycle的集成

  aohanyao

引言

引入Rx系列有一个非常大的缺陷:容易造成内存泄露,大多数都是忘记取消订阅而造成的,本篇就以RxLifecycle进行封装,在底层实现自动订阅与取消订阅。

正文

分析

我们在之前的Android 之路 (4) - 对RxJava2的简单封装中,在BasePresenter中有一个unDisposable的方法,该方法会在onDestroyonDialogCance的时候调用,这已经从一定程度上避免了内存泄露,但是这不够的,接下来就来集成 Rxlifecycle 吧。

注意:Rxlifecycle 版本使用的是2

编码

引入 Rxlifecycle

library-core 中引入:

api 'com.trello.rxlifecycle2:rxlifecycle:2.2.1'
api 'com.trello.rxlifecycle2:rxlifecycle-android:2.2.1'
api 'com.trello.rxlifecycle2:rxlifecycle-components:2.2.1'

修改继承关系

  1. SwipeBackActivity

前面的文章中我们集成了 SwipeBackActivity 作为所有 Activity 的基类,所以我们只需要更改 SwipeBackActivity 继承 com.trello.rxlifecycle2.components.support.RxAppCompatActivity

  1. CandyBaseFragment

CandyBaseFragment 更改继承为 com.trello.rxlifecycle2.components.support.RxFragment

修改 BasePresenter

在前面的封装中,我们其实是没有持有 BaseView 的,这里我们需要更改一下,增加对 BaseView的引用,好做接下来的操作。

private BaseView mView;

public BasePresenter(BaseView mView) {
	this.mView = mView;
}

绑定生命周期

之前封装过一个用于切换线程的 getScheduler 方法,用于在所有的 presenter 中进行调用,所以接下来的代码就和 getScheduler 合并在一起,代码如下:

/**
     * 统一线程处理和绑定生命周期
     *
     * @turn
     * @par<T>
     */
    protected <E> FlowableTransformer<E, E> getScheduler() {    //compose简化线程
        return new FlowableTransformer<E, E>() {
            @Override
            public Flowable<E> apply(Flowable<E> observable) {
                // 最终用于订阅的
                LifecycleTransformer<E> bindUntilEvent = null;
                // ---------------------------------判断是相应的类型,进行绑定------------
                if (mView instanceof RxAppCompatActivity) {
                    bindUntilEvent = ((RxAppCompatActivity) mView).bindUntilEvent(ActivityEvent.DESTROY);
                }
                if (mView instanceof RxFragmentActivity) {
                    bindUntilEvent = ((RxFragmentActivity) mView).bindUntilEvent(ActivityEvent.DESTROY);
                }
                if (mView instanceof RxActivity) {
                    bindUntilEvent = ((RxActivity) mView).bindUntilEvent(ActivityEvent.DESTROY);
                }
                if (mView instanceof RxFragment) {
                    bindUntilEvent = ((RxFragment) mView).bindUntilEvent(FragmentEvent.DESTROY);
                }
                if (mView instanceof com.trello.rxlifecycle2.components.support.RxFragment) {
                    bindUntilEvent = ((com.trello.rxlifecycle2.components.support.RxFragment) mView).bindUntilEvent(FragmentEvent.DESTROY);
                }
                // ---------------------------------判断是相应的类型,进行绑定------------

                Flowable<E> flowable = observable.subscribeOn(Schedulers.io())
                        .observeOn(AndroidSchedulers.mainThread());

                if (bindUntilEvent != null) {
                    //绑定
                    flowable = observable.subscribeOn(Schedulers.io())
                            .observeOn(AndroidSchedulers.mainThread()).compose(bindUntilEvent);
                }
                return flowable;
            }
        };
    }

运行

其它地方并没有什么修改,getScheduler的变更是完全兼容以前的老版本的,另外本次修改也和上次看不出什么区别,所以我们直接运行看看吧。

结束

其它

本次顺便修改了login的请求地址,以前使用的临时域名已经失效了。

总结

本文篇幅较少,只做了集成介绍和一个小问题的解决方案,这次封装在短期是看不出效果的。

源码-tag-v0.10

如果可以的话,请给我一个star 仓库地址

广告

来都来了,就给个关注吧,时不时会悄悄的推送一些小技巧的文章~~
AndroidRookie

软广

来都来了,就给个关注吧,时不时会悄悄的推送一些小技巧的文章~~!
FullScreenDeveloper