#RxJava
参考：http://gank.io/post/560e15be2dca930e00da1083
##异步
###扩展的观察者模式 RxJava作为一个工具库，使用的是通用形式的观察者模式。如下图：
##RxJava的观察者模式
RxJava的四个基本概念：
- Observable 可观察者，即被观察者
- Observer 观察者
- subscribe 订阅，事件
- Observable和Observer通过subscribe()方法实现订阅关系，从而Observable可以在需要的时候发出事件来通知Observer
与传统观察者模式不同，RxJava的事件回调方法除了普通事件onNext()(相当于onClick()/onEvent())之外，还定义了两个特殊的事件：onCompleted()和onError()。
- onCompleted():事件队列完结。RxJava不仅把每个事件单独处理，还会把它们看做一个队列。RxJava规定，当不会再有新的onNext()发出时，需要触发onCompleted()方法作为标志。
- onError():事件队列异常。在事件处理过程中出异常时，onError()会被触发，同时队列自动终止，不允许再有事件发出。
- 在一个正确运行的事件序列中，onCompleted()和onError()有且只有一个，并且是时间序列中的最后一个。需要注意的是，onCompleted()和onError()二者也是互斥的，即在队列中调用了其中一个，就不应该再调用另一个。
RxJava的观察者模式大致如下图：
###基本实现
- 创建 Observer
- 创建 Observable
- Subscribe (订阅)
###线程控制 —— Scheduler
###变换
所谓变换，就是将事件序列中的对象或整个序列进行加工处理，转换成不同的事件或事件序列。
- 使用传入的事件对象创建一个 Observable 对象；
- 并不发送这个 Observable, 而是将它激活，于是它开始发送事件；
- 每一个创建出来的 Observable 发送的事件，都被汇入同一个 Observable ，而这个 Observable 负责将这些事件统一交给 Subscriber 的回调方法。这三个步骤，把事件拆成了两级，通过一组新创建的 Observable 将初始的对象『铺平』之后通过统一路径分发了下去。而这个『铺平』就是 flatMap() 所谓的 flat。
###变换的原理: lift()
变换的实质是，针对事件序列的处理和再发送。