Rx是Reactive Extensions的簡寫，翻譯為響應(yīng)的擴展。
Rx社區(qū)網(wǎng)站 ==> http://reactivex.io
RxAndroid社區(qū)網(wǎng)站 ==> https://github.com/ReactiveX/RxAndroid
## rxjava2.0依賴
compile 'io.reactivex:rxandroid:1.2.1'
compile 'io.reactivex:rxjava:1.1.6'
## rxjava2.0依賴
compile 'io.reactivex.rxjava2:rxandroid:2.0.2'
compile 'io.reactivex.rxjava2:rxjava:2.x.x'
## 最簡單的例子
//1.創(chuàng)建被觀察者
Observable<String> observable =
Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
//事件有3個類型 分別是onNext() onCompleted() onError()
//onCompleted() onError() 一般都是用來通知觀察者 事件發(fā)送完畢了,兩者只取其一墓猎。
subscriber.onNext("Hello Android !");
subscriber.onNext("Hello Java !");
subscriber.onNext("Hello C !");
subscriber.onCompleted();
}
});
//2.創(chuàng)建觀察者
Subscriber<String> subscriber = new Subscriber<String>() {
@Override
public void onCompleted() {
Log.i(TAG, "onCompleted ");
}
@Override
public void onError(Throwable e) {
Log.i(TAG, "onError: "+e.getLocalizedMessage());
}
@Override
public void onNext(String s) {
Log.i(TAG, "onNext: "+s);
}
};
//3.訂閱
observable.subscribe(subscriber);
最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
