相信使用過RxJava、RxAndroid的人都會被其簡便的流式操作所吸引李滴，結(jié)合java8的lambda表達(dá)式螃宙，使代碼看起來更簡潔，操作邏輯更清晰悬嗓，數(shù)據(jù)處理更便捷污呼，告別了臃腫的代碼。但要優(yōu)雅的使用它還需要進(jìn)行一些處理包竹，避免操作不當(dāng)導(dǎo)致的內(nèi)存泄漏風(fēng)險(xiǎn)燕酷。
管理訂閱的幾種方式
- 使用CompositeSubscription統(tǒng)一管理生命周期(后面具體講解實(shí)現(xiàn)方式)
- 使用RxLifecycle來管理訂閱，實(shí)現(xiàn)和Android組件的生命周期綁定周瞎。
- 使用takeUntil操作符結(jié)合BehaviorSubject實(shí)現(xiàn)生命周期綁定苗缩。
具體介紹
一、使用CompositeSubscription統(tǒng)一管理生命周期
public class BaseActivity extends AppCompatActivity {
protected CompositeSubscription subscription = new CompositeSubscription();
protected void addSub(Subscription sub) {
if (sub != null && !sub.isUnsubscribed()) {
subscription.add(sub);
}
}
@Override
protected void onDestroy() {
if(subscription.hasSubscriptions()){
subscription.unsubscribe();
}
super.onDestroy();
}
}
在子類統(tǒng)一調(diào)用addSub方法將生成的訂閱關(guān)系添加進(jìn)subscription管理類中声诸，在onDestroy中統(tǒng)一取消訂閱關(guān)系酱讶。
二、使用RxLifecycle來管理訂閱(需要引入新的類庫)
這里不進(jìn)行詳細(xì)描述彼乌，具體操作參照Rxlifecycle使用詳解
三泻肯、使用takeUntil操作符結(jié)合BehaviorSubject實(shí)現(xiàn)生命周期綁定
具體代碼實(shí)現(xiàn)：
//這里提供的是kotlin的實(shí)現(xiàn)
class MainActivity : AppCompatActivity() {
var subject: BehaviorSubject<Event> = BehaviorSubject.create()
val TAG = MainActivity::class.java!!.simpleName
override fun onCreate(@Nullable savedInstanceState: Bundle?) {
super.onCreate(savedInstanceState)
setContentView(R.layout.activity_main)
var sub = Observable.interval(1, TimeUnit.SECONDS)
.compose(this.bindLife<Long>())
.subscribe({ a -> Log.i(TAG, "call: " + a!!) },
{ t -> Log.e(TAG, "call: " + t.message!!) }
, { Log.i(TAG, "complete: 完成") })
}
fun <T> bindLife(): Observable.Transformer<T, T> {
return Observable.Transformer<T, T> {
observable -> observable.takeUntil(subject.skipWhile(
{event ->event != Event.PAUSE && event != Event.DESTROY
&& event != Event.DETACH }))}
}
override fun onDestroy() {
subject.onNext(Event.DESTROY)
super.onDestroy()
}
}
enum class Event {
// Activity life Events
CREATE,
START,
RESUME,
PAUSE,
STOP,
DESTROY,
// Fragment life Events
ATTACH,
CREATE_VIEW,
DESTROY_VIEW,
DETACH
}
java版本(非lambda)
/**
* ClassName: BaseActivity<p>
* Author: Alpha<p>
* Fuction: <p>
* CreateDate: 2016/7/3 0:17<p>
*/
public class BaseActivity extends AppCompatActivity {
protected BehaviorSubject<Event> subject = BehaviorSubject.create();
@Override
protected void onCreate(@Nullable Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
Observable.interval(3, TimeUnit.SECONDS)
.compose(this.<Long>bindLife())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Subscriber<Long>() {
@Override
public void onCompleted() {
Log.i("rxjava", "onCompleted");
Toast.makeText(BaseActivity.this, "onCompleted", Toast.LENGTH_SHORT).show();
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(final Long aLong) {
Log.i("rxjava", "onNext " + aLong);
Toast.makeText(BaseActivity.this, "aLong:" + aLong, Toast.LENGTH_SHORT).show();
}
});
}
protected <T> Observable.Transformer<T, T> bindLife() {
return new Observable.Transformer<T, T>() {
@Override
public Observable<T> call(Observable<T> observable) {
return observable.takeUntil(subject.skipWhile(new Func1<Event, Boolean>() {
@Override
public Boolean call(Event event) {
return event != Event.DESTROY && event != Event.DETACH;
}
}));
}
};
}
@Override
protected void onDestroy() {
subject.onNext(Event.DESTROY);
super.onDestroy();
}
}
未處理之前.gif
處理之后.gif
感謝大家的支持，如有不足之處希望大家提出來慰照，一起交流進(jìn)步灶挟。
