一年前，自己搭建项目框架的时候，就已经接触用过RxJava，并且还和Retrofit结合一起使用。然而却并不清楚RxJava，到底是个啥子东西，只知道按摸就样的用着。网上有篇文章对RxJava介绍很详细 抛物线大神 ，一年前看这篇文章和现在看，有不同的收获吧。
那到底啥是RxJava? 官方介绍
a library for composing asynchronous and event-based programs by using observable sequences.
It extends the observer pattern to support sequences of data/events and adds operators
that allow you to compose sequences together declaratively
while abstracting away concerns about things
like low-level threading, synchronization, thread-safety and concurrent data structures.
英语捉急，只能借助有道爸爸：
使用可观察的序列来编写异步和基于事件的程序的库。
它扩展了观察者模式，以支持数据/事件的序列，并添加操作符，
使您能够在抽象地消除对低层次线程、同步、线程安全和并发数据结构的关注时，以声明的方式组合这些序列。
还是看不懂，看来语文也捉急。
网上说的最多的就是Rxjava的异步性，当然同样的可以实现异步常规操作，大多用AsyncTask / Handler 。既然市面上那么多人推崇Rxjava，那它肯定有存在的必要。
废话也不讲，慢慢了解它
要学习Rxjava，不得不知道这几个对象：Observable/ Subscriber(可观察者，即被观察者,这两者区别，后者增加订阅和取消订阅监听)、 Observer (观察者)、 subscribe (订阅)、事件。
这几个对象的关系其实就和onClick类似，抽象的描述可以比喻：Observable 就像是直播平台的主播，Observer 则是用户，通过用户订阅主播这个动作，两者达成了一个联系。每次主播开播动作，就能通知到用户这边做对应动作，看直播或者做其他事情。与onClick比较，他强大之处，主播的动作也可以自定义，以及可以控制主播和用户，具体在哪个线程中进行。我想这就是Rxjava的强大之一
基本实现：
1.创建 Observe
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!");
}
};
2.创建 Observable 另外还有 just/from 等创建方法就不一一阐述
Observable observable = Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
subscriber.onNext("Hello world");
subscriber.onCompleted();
}
});
3.Subscribe (订阅)
observable.subscribe(observer);
// 或者：
observable.subscribe(subscriber);
Subscribe内部源码大致是这样（copy抛物线大神,源码实在太杂）
public Subscription subscribe(Subscriber subscriber) {
subscriber.onStart();
onSubscribe.call(subscriber);
return subscriber;
}
Onstart执行的类似Subscriber 的生命周期的概念，这是一个可选方法，默认情况下它的实现为空。
.call(Subscriber)在这里，事件发送的逻辑开始运行。从这也可以看出，在 RxJava 中， Observable 并不是在创建的时候就立即开始发送事件，而是在它被订阅的时候，即当 subscribe() 方法执行的时候。
线程控制 —— Scheduler
RxJava 另一个牛逼的地方，就是线程的自由控制，多次切换线程。
** observeOn()** ** subscribeOn()** 两个方法，指定对应的工作在指定的线程进行
示例代码：
Observable.just(1, 2, 3, 4) // IO 线程，由 subscribeOn() 指定
.subscribeOn(Schedulers.io())
.observeOn(Schedulers.newThread())
.map(mapOperator) // 新线程，由 observeOn() 指定
.observeOn(Schedulers.io())
.map(mapOperator2) // IO 线程，由 observeOn() 指定
.observeOn(AndroidSchedulers.mainThread)
.subscribe(subscriber); // Android 主线程，由 observeOn() 指定
通过 observeOn() 的多次调用，程序实现了线程的多次切换，不同于 observeOn() ， subscribeOn() 的位置放在哪里都可以，但它是只能调用一次的，当使用了多个 subscribeOn() 的时候，只有第一个 subscribeOn() 起作用
doOnSubscribe(): 如果在 doOnSubscribe() 之后有 subscribeOn() 的话，它将执行在离它最近的 subscribeOn() 所指定的线程。
操作符
RxJava 之所以强大，我觉得还因为他集成了各种API操作符，简直不要太全。
普通操作符包括：interval、repeat和intervalRange等。
变换操作符：map、flatMap、cast和concatMap等；这几个已经灵活用到各个应用场景
过滤操作符包括：filter、skip、take、element等等。
组合操作符包括：merge、startWidth、concat、jion、switch和zip等等。
辅助操作符包括：DO、delay、observeOn、timeout、timeInterval、timestamp、subscribeOn、meterialize和to等。
错误操作符包括：catch和retry。
条件操作符包括：defaultEmpty、skipUntil、amb、skipWhile、takeUtil、takeWhile。
布尔操作符包括：all、isEmpty、contains、exists和sequenceEqual。
转换操作符包括：toMap、toMultiMap、toList、toSortedList、nest和getIterator等
