Rxjava2生命周期绑定

    咱们在使用rxjava请求网络的时候，会出现一种状况，当咱们订阅后，activity销毁了，这个时候咱们的activity就没法被收回，从而引起形成内存泄漏，对此咱们可使用RxLifecycle来管理activity的生命周期，是用步骤很简单，就三步，依赖、继承、绑定。

使用步骤

依赖RxLifecycle

compile 'com.trello.rxlifecycle2:rxlifecycle:2.2.1'
    compile 'com.trello.rxlifecycle2:rxlifecycle-android:2.2.1'
    compile 'com.trello.rxlifecycle2:rxlifecycle-components:2.2.1'
复制代码

继承

继承RxAppCompatActivity或RxFragmentActivity等等，fragment也提供了相应的继承类

public class BaseActivity extends RxAppCompatActivity {


    @Override
    public void onCreate(@Nullable Bundle savedInstanceState, @Nullable PersistableBundle persistentState) {
        super.onCreate(savedInstanceState, persistentState);

    }

    @Override
    protected void onDestroy() {
        super.onDestroy();
    }
}
复制代码

绑定Activity

咱们使用compose操做符来绑定其生命周期,这里咱们使用

1. 使用bindUntilEvent绑定，传入的参数有六种，对应activity的生命周期， CREATE, START， RESUME, PAUSE, STOP, DESTROY，咱们想让其在何时取消订阅就传入对应的生命周期就行了，如如下例子为当生命周期处于stop的时候，取消订阅

compose((RxAppCompatActivity)context.bindUntilEvent(ActivityEvent.STOP))
复制代码

2. 使用bindToLifecycle方法绑定，这种方法跟随者activity的生命周期，当activity销毁的时候取消订阅

compose(baseApi.getActivity().bindToLifecycle())
复制代码

绑定原理

在说绑定原理以前首先提两个东西，

1. BehaviorSubject，这个Subject是官方提供的，做用是“释放订阅前最后一个数据和订阅后接收到的全部数据”，简单的说，他就是onNext来存储数据，而后在订阅的时候将数据发送出去。这个类暂时理解到这。
2. takeUntil操做符，“当第二个Observable发射了一项数据或者终止时，丢弃原Observable发射的任何数据”。这个说明白一点就是当收到某个observable的某个事件时，自动取消订阅（某个observable就是BehaviorSubject）

bindUntilEvent绑定原理

    调用bindUntilEvent方法时，会传入两个参数，一个是BehaviorSubject，一个是咱们设定的ActivityEvent，这里的BehaviorSubject上面说了是在订阅的时候将数据发送出去，BehaviorSubject在activity的时候会调用onNext将生命周期传入进去

    再跟入bindUntilEvent方法，咱们能够看到他执行了一个bind方法，而且bing方法中作了一个处理，去判断当前的生命周期与咱们传入的生命周期是否相等，若是不相等，则不会将值发送到Subscriber

    在bind方法中，建立了一个LifecycleTransformer而且传入observable，在LifecycleTransformer的构造中将这个observable存储为成员，用于takeUnti方法的执行（该方法的做用上面说了，若是observable发送了值过来就会自动取消订阅）

    总结一下bindUntilEvent的生命周期绑定原理：就是运用到BehaviorSubject和takeUntil，当BehaviorSubject发送出来的生命周期与咱们传入的生命周期相等的时候则取消订阅，不相等，则不取消，是否相等在过滤器（filter）中处理的

bindToLifecycle绑定原理

    根据当前的生命周期，来进行运算获得一个新的序列，这个序列为boolean序列，当为true的时候则取消订阅，核心方法为takeUntilCorrespondingEvent方法中的combineLatest combineLatest参数

1. lifecycle.take(1)指的是最近发射的事件

   这里就是指ACTIVITY_LIFECYCLE中对应的参数，若是当前生命周期为create，则返回的是ActivityEvent.DESTROY

2. lifecycle.skip(1)指除去第一个保留剩下的

   这里就是指咱们除去咱们当前的生命周期，剩下的，例如咱们当前处于create中执行了bindToLifecycle，则六个生命周期中就去除掉create，剩下的五个

3. 第三个参数 意味着，lifecycle.take(1).map(correspondingEvents)的序列和 lifecycle.skip(1)进行combine，造成一个新的序列

   咱们用ACTIVITY_LIFECYCLE中获得的对应的参数去与咱们第二个参数中的获得的剩下的生命周期序列作比较，而后获得一串Boolean序列，当为true的时候则取消订阅