學(xué)無止境
Rxlifecycle是用于解決RxJava引起的內(nèi)存泄漏的開源框架。
此次選擇的方案：使用Rxlifecycler的組件和提供的RxActivity、RxFragment等類的子類
首先根據(jù)方案添加依賴：
implementation 'com.trello.rxlifecycle2:rxlifecycle:2.1.0'
implementation 'com.trello.rxlifecycle2:rxlifecycle-components:2.1.0'
然后繼承RxActivity，RxFragment；
-
bindUntilEvent(ActivityEvent.STOP)：手動(dòng)設(shè)置在onPause()的時(shí)候取消訂閱；
Flowable.interval(2, TimeUnit.SECONDS)
.compose(this.bindUntilEvent(ActivityEvent.STOP))
.subscribe(new Consumer<Object>() {
@Override
public void accept(Object o) throws Exception {
Log.d("flag", "onStart-------------");
}
});
bindToLifecycle()的自動(dòng)取消訂閱，如果在onStart()的時(shí)候調(diào)用，所以在onStop()的時(shí)候自動(dòng)取消訂閱；
@Override
protected void onStart() {
super.onStart();
//自動(dòng)綁定生命周期
Flowable.interval(2, TimeUnit.SECONDS)
.compose(this.<Long>bindToLifecycle())
.subscribe(new Consumer<Object>() {
@Override
public void accept(Object o) throws Exception {
Log.d("flag", "onStart-------------");
}
});
}
RxLifecycle實(shí)際上并不取消訂閱序列。而是終止序列。方式根據(jù)類型而有所不同：
-
Observable，Flowable和Maybe：發(fā)射onCompleted()終止序列； -
Single和Completable：發(fā)射onError(CancellationException)終止序列；
如果需要取消訂閱，仍需手動(dòng)取消；
該方案的源碼解析
RxActivity：
關(guān)于BehaviorSubject，作為Subject的實(shí)現(xiàn)類，擁有著它們的公共屬性：既是觀察者，也是被觀察者
同時(shí)BehaviorSubject也擁有區(qū)別于其他三個(gè)實(shí)現(xiàn)類的特征：發(fā)送訂閱之前一個(gè)數(shù)據(jù)和訂閱之后的全部數(shù)據(jù)；如果沒有數(shù)據(jù)就發(fā)送一個(gè)默認(rèn)值
上圖中表示在
Activity的所有生命周期方法中，lifecycleSubject通過onNext()將標(biāo)志著生命周期的事件發(fā)射給下游；發(fā)出的生命周期事件，如果和自己綁定的生命周期事件一樣，那就終止序列，從而管理RxJava的生命周期；
.compose(this.bindUntilEvent(ActivityEvent.STOP))配置綁定終止序列的生命周期，其中bindUntilEvent()源碼如下：
上文takeUntilEvent()中filter()操作符來判斷發(fā)射給下游的事件和自己綁定的生命周期是否一樣，一樣就繼續(xù)向下游走；
takeUntil()操作符是關(guān)鍵，TakeUntil：當(dāng)傳入的那個(gè)被觀察者發(fā)射數(shù)據(jù)的時(shí)候，當(dāng)前這個(gè)被觀察者就不再發(fā)射數(shù)據(jù)；
總結(jié)：當(dāng)應(yīng)用調(diào)用onStop()方法時(shí)，發(fā)射給下游的事件和綁定的事件一致，傳入takeUntil()的被觀察者就會(huì)發(fā)射數(shù)據(jù)，然后當(dāng)前的被觀察者就會(huì)終止序列；
對(duì)于RxJava的學(xué)習(xí)才剛剛開始！
RxJava：RxBus事件總線
RxJava：RxBinding
RxJava：Rxlifecycle
