學(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)：手動設(shè)置在onPause()的時候取消訂閱；
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()的自動取消訂閱掺冠，如果在onStart()的時候調(diào)用，所以在onStop()的時候自動取消訂閱码党；
@Override
protected void onStart() {
super.onStart();
//自動綁定生命周期
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實際上并不取消訂閱序列德崭。而是終止序列。方式根據(jù)類型而有所不同：
-
Observable揖盘，Flowable和Maybe：發(fā)射onCompleted()終止序列眉厨； -
Single和Completable：發(fā)射onError(CancellationException)終止序列；
如果需要取消訂閱兽狭，仍需手動取消憾股；
該方案的源碼解析
RxActivity：
關(guān)于BehaviorSubject鹿蜀，作為Subject的實現(xiàn)類，擁有著它們的公共屬性：既是觀察者荔燎，也是被觀察者
同時BehaviorSubject也擁有區(qū)別于其他三個實現(xiàn)類的特征：發(fā)送訂閱之前一個數(shù)據(jù)和訂閱之后的全部數(shù)據(jù)耻姥；如果沒有數(shù)據(jù)就發(fā)送一個默認(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)傳入的那個被觀察者發(fā)射數(shù)據(jù)的時候淳衙，當(dāng)前這個被觀察者就不再發(fā)射數(shù)據(jù)蘑秽；
總結(jié)：當(dāng)應(yīng)用調(diào)用onStop()方法時，發(fā)射給下游的事件和綁定的事件一致箫攀，傳入takeUntil()的被觀察者就會發(fā)射數(shù)據(jù)肠牲，然后當(dāng)前的被觀察者就會終止序列；
對于RxJava的學(xué)習(xí)才剛剛開始靴跛！
RxJava：RxBus事件總線
RxJava：RxBinding
RxJava：Rxlifecycle
