Rxjava是基于jvm的可观测序列的处理异步事件的程序库。其基本理念是被观察者(observable)发送数据，这些数据通过被观察者调用操作符处理，然后这些被处理过的数据发送给订阅了的观察者(Observer)。共有五种基本类型(observable)可以使用操作符：
- Flowable 能发送0到n个项目，支持响应流和背压
- Observable 能发送0到n个项目，不支持背压
- Single 仅支持返回一个项目或者一个错误
- Completable 没有返回，仅仅只有完成或者错误，相当于void
- Maybe 能够发射0或者1个数据，要么成功，要么失败。
由于subject继承了被观察者(observable)，实现了观察者(observer)接口，因此subject既可以被认为是观察者，也可以被认为是被观察者。因此通过subject订阅被观察者，就可以实现cold observable到hot observable的转换。
背压就是生产的数据太快了，而消费者处理不了那么快。那么就让生产者低速生产的方式。也可以通过其他方案解决搜索框延迟搜索的问题，sample,throttle 都有类似debounce的这个功能。如果想要收集中间的变化结果，可以使用buffer或者window。
interval不支持背压，而range支持背压，支持背压则可以通过request()操作符进行限制。是否支持背压涉及到Cold Observables和Hot Observables，前者表示在订阅之后才开始发送事件的Observable。后者表示不管是否订阅，创建就会发送事件的。cold Observables 中也有不支持背压的(interval ,timer)，hot Observables则都不支持背压。
subject的子类有下面几种，他们也都同时具有观察者和被观察者的身份：
- publishSubject只会把在订阅发生的时间点之后来自原始Observable的数据发射给观察者。
- ReplaySubject会发射所有来自原始Observable的数据给观察者，无论它们是何时订阅的。
- BehaviorSubject 当被订阅时，它开始发射原始Observable最近发射的数据（如果此时还没有收到任何数据，它会发射一个默认值），然后继续发射其它任何来自原始Observable的数据。
- AsyncSubject只在原始Observable完成后，发射来自原始Observable的最后一个值。
- SerializedSubject 同时保证只有一个线程操作，但不保证所有操作都是同一个线程。
Rxjava是观察者模式和迭代器模式相结合的函数式编程的精华。
迭代器模式是消费者从生产者那里pull拉取数据，线程阻塞直到数据准备好。observable则是在数据准备好后，生产者将数据推送给消费者。这里的迭代器模式理解为生产消费模式更好。生产消费模式中间采用了阻塞队列来缓冲。
明白了观察者和被观察者之间的关系之后，就是如何应用操作符了。操作符讲解，可以查看文档。
网友评论