RxJava2.x文档
什么是RxJava
Rx是异步响应式编程的意思，本质是观察者模式，以观察者和订阅者的异步响应式编程。
RxJava 2.0 最核心的是Flowable和Subscriber，Observable和Observer。Observable用于订阅Observer，是不支持背压的，而Flowable用于订阅Subscriber，是支持背压(Backpressure)的。
Hello RxJava2
添加依赖：
//RxJava的依赖包 compile'io.reactivex.rxjava2:rxjava:2.0.1'
//RxAndroid的依赖包 compile'io.reactivex.rxjava2:rxandroid:2.0.1'
创建Observable
Observable observable = Observable.create(newObservableOnSubscribe() {
@Override
public void subscribe(ObservableEmitter e) throws Exception {
e.onNext("Hello RxJava 2");
}
});
创建Observer
Observer observer =newObserver() {
@Override
public void onSubscribe(Disposable disposable) {
Log.e(TAG,"onSubscribe");
}
@Override
public void onNext(String s) {
Log.e(TAG,s);
}
@Override
public void onError(Throwable throwable) {
}
@Override
public void onComplete() {
Log.e(TAG,"onComplete");
}
};
订阅：
observable.subscribe(observer);
使用create( )创建Observable最基本的创建方式。可以看到，这里传入了一个 ObservableOnSubscribe对象作为参数，它的作用相当于一个计划表，当 Observable被订阅的时候，ObservableOnSubscribe的subscribe()方法会自动被调用，事件序列就会依照设定依次触发（对于上面的代码，就是观察者Observer 将会被调用一次 onNext()）。这样，由被观察者调用了观察者的回调方法，就实现了由被观察者向观察者的事件传递，即观察者模式
Observable 原理
Observable的其他创建方式：
just()方式
Observable observable = Observable.just("Hello");
使用just( )，将为你创建一个Observable并自动为你调用onNext( )发射数据。通过just( )方式 直接触发onNext()，just中传递的参数将直接在Observer的onNext()方法中接收到。
fromIterable()方式
List list = newArrayList();
for(int i =0;i <10;i++) {
list.add("Hello RxJava"+ i);
}
Observable.fromIterable(list).subscribe(newConsumer() {
@Override
public void accept(@NonNullString s)throwsException {
Log.e(TAG,s);
}
});
使用fromIterable()，遍历集合，发送每个item。相当于多次回调onNext()方法，每次传入一个item。
interval( )方式
Observable observable =Observable.interval(2, TimeUnit.SECONDS);
创建一个按固定时间间隔发射整数序列的Observable，可用作定时器。即按照固定2秒一次调用onNext()方法。
range( )方式
Observable observable = Observable.range(1,20);
创建一个发射特定整数序列的Observable，第一个参数为起始值，第二个为发送的个数，如果为0则不发送，负数则抛异常。上述表示发射1到20的数。即调用20次nNext()方法，依次传入1-20数字。
timer( )方式
Observable observable =Observable.timer(2, TimeUnit.SECONDS);
创建一个Observable，它在一个给定的延迟后发射一个特殊的值，即表示延迟2秒后，调用onNext()方法。
repeat( )方式
Observable observable = Observable.just("Hello RxJava2.0").repeat();
创建一个Observable，该Observable的事件可以重复调用
