RxJava有四個(gè)基本概念
- 被觀察者 Observable
- 觀察者 Observer
- 訂閱 Subscribe
- 事件
事件回調(diào)方法
- onNext( ) , 相當(dāng)于onClick( )
- onCompleted( )
- onError( )
基本實(shí)現(xiàn)
1.創(chuàng)建觀察者 (Observer) -- 事件觸發(fā)后的行為
Observer接口的實(shí)現(xiàn)方式:
Observer<String> observer = new Observer<String>() {
@Override
public void onNext(String s) {
Log.d(tag, "Item: " + s);
}
@Override
public void onCompleted() {
Log.d(tag, "Completed!");
}
@Override
public void onError(Throwable e) {
Log.d(tag, "Error!");
}
};
Subscriber 基本使用方式:
Subscriber<String> subscriber = new Subscriber<String>(){
@Override
public void onNext(String s) {
Log.d(tag, "Item: " + s);
}
@Override
public
void onCompleted() {
Log.d(tag, "Completed!");
}
@Override
public void onError(Throwable e) {
Log.d(tag, "Error!");
}
};
Observer 會(huì)被先轉(zhuǎn)換成Subscriber再使用坝冕，兩者基本使用方式一樣。
區(qū)別:
-
onStart(): 這是 Subscriber增加的方法蹋肮。
它會(huì)在 subscribe 剛開(kāi)始园蝠，而事件還未發(fā)送之前被調(diào)用惠爽，可以用于做一些準(zhǔn)備工作巩螃，例如數(shù)據(jù)的清零或重置媒峡。這是一個(gè)可選方法翠桦，默認(rèn)情況下它的實(shí)現(xiàn)為空苟蹈。
需要注意的是糊渊，如果對(duì)準(zhǔn)備工作的線程有要求（例如彈出一個(gè)顯示進(jìn)度的對(duì)話框，這必須在主線程行慧脱， onStart()就不適用了渺绒，因?yàn)樗偸窃?subscribe 所發(fā)生的線程被調(diào)用，而不能指定線程菱鸥。要在指定的線程來(lái)做準(zhǔn)備工作宗兼，可以使用 doOnSubscribe()方法，具體可以在后面的文中看到氮采。 -
unsubscribe(): 這是 Subscriber所實(shí)現(xiàn)的另一接口Subscription的方法殷绍，用于取消訂閱。
在這個(gè)方法被調(diào)用后鹊漠，Subscriber將不再接收事件主到。一般在這個(gè)方法調(diào)用前，可以使用 isUnsubscribed()先判斷一下?tīng)顟B(tài)躯概。
unsubscribe()這個(gè)方法很重要登钥，因?yàn)樵?subscribe()后， Observable會(huì)持有 Subscriber的引用娶靡，這個(gè)引用如果不能及時(shí)被釋放牧牢，將有內(nèi)存泄露的風(fēng)險(xiǎn)。
所以最好保持一個(gè)原則：要在不再使用的時(shí)候盡快在合適的地方（例如 onPause() onStop() 等方法中）調(diào)用unsubscribe()來(lái)解除引用關(guān)系固蛾，以避免內(nèi)存泄露的發(fā)生结执。
2.創(chuàng)建被觀察者 (Observable)
決定什么時(shí)候觸發(fā)度陆，觸發(fā)怎樣的事件
Observable observable = Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
subscriber.onNext("Hello");
subscriber.onNext("Hi");
subscriber.onNext("Aloha");
subscriber.onCompleted(); }
});
OnSubscribe會(huì)被存儲(chǔ)在返回的 Observable對(duì)象中艾凯，它的作用相當(dāng)于一個(gè)計(jì)劃表
當(dāng) Observable被訂閱的時(shí)候 call()方法會(huì)自動(dòng)被調(diào)用，事件序列就會(huì)依照設(shè)定依次觸發(fā)
這樣懂傀，由被觀察者調(diào)用了觀察者的回調(diào)方法趾诗，就實(shí)現(xiàn)了由被觀察者向觀察者的事件傳遞，即觀察者模式。
快捷創(chuàng)建事件隊(duì)列:
- just(T...): 將傳入的參數(shù)依次發(fā)送出來(lái)恃泪。
Observable observable = Observable.just("Hello", "Hi", "World");
// 將會(huì)依次調(diào)用：
// onNext("Hello");
// onNext("Hi");
// onNext("Aloha");
// onCompleted();
- from(T[ ])/ from(Iterable<? extends T>) : 將傳入的數(shù)組或 Iterable拆分成具體對(duì)象后郑兴，依次發(fā)送出來(lái)
String[] words = {"Hello", "Hi", "Aloha"};
Observable observable = Observable.from(words);
// 將會(huì)依次調(diào)用：
// onNext("Hello");
// onNext("Hi");
// onNext("Aloha");
// onCompleted();
3.訂閱(Subscribe)
observable.subscribe(observer);
或者：
observable.subscribe(subscriber);
或者不完整定義的回調(diào), 自動(dòng)創(chuàng)建Subscriber:
Action1<String> onNextAction = new Action1<String>() {
// onNext()
@Override
public void call(String s) {
Log.d(tag, s);
}};
Action1<Throwable> onErrorAction = new Action1<Throwable>() {
// onError()
@Override
public void call(Throwable throwable) {
// Error handling
}};
Action0 onCompletedAction = new Action0() {
// onCompleted()
@Override
public void call() {
Log.d(tag, "completed");
}};
// 自動(dòng)創(chuàng)建 Subscriber ，并使用 onNextAction 來(lái)定義onNext()
observable.subscribe(onNextAction);
// 自動(dòng)創(chuàng)建 Subscriber 贝乎，并使用 onNextAction 和 onErrorAction 來(lái)定義 onNext() 和 onError()
observable.subscribe(onNextAction, onErrorAction);
// 自動(dòng)創(chuàng)建 Subscriber 情连，并使用 onNextAction、 onErrorAction 和 onCompletedAction 來(lái)定義 onNext()览效、 onError() 和 onCompleted()
observable.subscribe(onNextAction, onErrorAction, onCompletedAction);
