Rxjava 简介

观察者模式的：

就是A动 B 就一定懂；那么a就是被观察者；b就是观察者； 观察者对被观察者的变化高度敏

感；需要在被观察者变化的一瞬间做出反应； 程序的注册或者称为订阅的方式 告诉观察者

我需要你的某某状态；你要在变化的时候通知我；Android开发中一个比较典型的例子是点击

监听器onClickListener 对设置onclickListener 来说 view 是被观察者；

onClickListener  是观察者； 两者通过setOnClickListener()方法达成订阅关系；还有一

个是接口回调；

RxJava 有四个概念；observable 可观察者；oberver 观察者；subscribe 订阅 和事件；

obervable和observer 通过subscrible()方法形成订阅关系；从而observable可以在需要的

饿时候发事件通知observer

和传统的观察者模式 不同rxjava的时间回调方法除了普通时间onNext() 相当于onclick

()/onEvent() 之外；还有连个特殊的时间 onCompltetd() 和onError（）

onCompleted() z这个是时间队列的完结；RxJava 不仅把每个时间单独处理，还会把他们看作

队列；RxJava 规定 当不会再有新的onnext() 发出的时候 需要出发OnCompleted（）方法作

为标志；

onError 时间队列异常； 在时间处理过程中异常时，onError会被出发；同时队列自动终止；

不允许有时间发出；再有事件发出；

在一个正确运行的时间序列中 oncompleted 和onError 这两个方法有且只有一个，并且是时

间的最后一个；需要注意的这两个也是互斥的；