RxJava

RxJava & RxAndroid

RxJava的基本認知
RxJava 重要的核心概念為Observables和Subscribers

• Observables > 被觀察者
• Subscribers > 訂閱者

舉例來說，你可以訂閱某部落格(Observables)，而當部落格發文時，訂閱者(Subscribers)就會收到通知。

而這個概念就是異步(Async)。

RxJava的操作方式

// 建立被觀察者
Observable<String> observable = Observable.create(
new Observable.OnSubscribe<String>(){

@Override
public void call(Subscriber<? super String> subscriber) {
// 執行
subscriber.onNext("Hello World");
subscriber.onCompleted();
}
}
);

建立被觀察者後，還需要有訂閱者

// 建立訂閱者
Subscriber<String> subscriber = new Subscriber<String>() {
// 當觀察者執行完畢後，會告知訂閱者並執行onCompleted
@Override
public void onCompleted() {
printlog("OnCompleted");
}

@Override
public void onError(Throwable e) {

}

// 觀察者發布onNext時，訂閱者接收後的處理
@Override
public void onNext(String s) {
printlog(s);
}
};

當被觀察者和訂閱者都建立之後，被觀察者需要設定發布對象(訊息要丟給哪一個訂閱者)

註冊訂閱者
observable.subscribe(subscriber);
如此一來，當observable進行資料處理完畢之後，subscriber就會馬上得到通知，並且進行相應的處理。

簡化

當你理解前面的概念後，可以更簡單的使用

以下方法也能實現上面的功能

// 建立被觀察者
Observable<String> observable = Observable.just("Hello World");

// 建立訂閱者
Action1<String> action1 = new Action1<String>() {
@Override
public void call(String s) {
printlog(s);
}
};
observable.subscribe(action1);

其中Action也可以定義 onNext、onError、onCompleted

上面是簡化後的被觀察者與訂閱者可讀性較高的寫法
以下將使用另一種方式呈現更簡化的寫法

Observablel.just("Hello world").subscribe(new Action1<String>(){
public void call(String s){
System.out.println(s);
}
});

以上基本操作介紹完畢!