引言

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

正文

分析

我们在之前的Android 之路 (4) - 对RxJava2的简单封装中，在BasePresenter中有一个unDisposable的方法，该方法会在onDestroy和onDialogCance的时候调用，这已经从一定程度上避免了内存泄露，但是这不够的，接下来就来集成 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。

2. 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的变更是完全兼容以前的老版本的，另外本次修改也和上次看不出什么区别，所以我们直接运行看看吧。

image

结束

其它

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

总结

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

源码-tag-v0.10

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

广告

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

AndroidRookie