学习文章链接：http://www.jianshu.com/p/464fa025229e
感谢Season_zlc大神的讲解。
private void demo1(){
// 创建一个上游observeble
Observable observable = Observable.create(new ObservableOnSubscribe() {
@Override
public void subscribe(ObservableEmitter emitter)throwsException {
emitter.onNext(1);
emitter.onNext(2);
emitter.onNext(3);
emitter.onNext(4);
emitter.onComplete();
}
});
//创建一个下游
Observer observer =newObserver() {
@Override
public void onSubscribe(Disposable d) {
Log.d(TAG,"subscribe");
}
@Override
public void onNext(Integer value) {
Log.d(TAG,""+ value);
}
@Override
public void onError(Throwable e) {
Log.d(TAG,"error");
}
@Override
public void onComplete() {
Log.d(TAG,"complete");
}
};
//建立连接
observable.subscribe(observer);
}
最简单的一种创建上游、下游并建立连接。
第二种
线程的切换使用
学习retrofit的使用，并结合rxjava封装简单的网络请求
学习文章：http://www.jianshu.com/p/229cd2f0d629
api从http://www.jianshu.com/p/56f15db86ed3中借鉴，感谢
api为：http://api.laifudao.com/open/xiaohua.json
