观察者模式：当一个对象发生变化时，依赖它的所有对象都会被通知并且会自动更新
RxJava是典型的观察者模式
生产者在没有更多数据可用时能够发出信号通知：onCompleted()
事件生产者在发生错误时能够发出信号通知onError()
事件RxJava Observables能够组合而不是嵌套，从而避免开发者陷入回调地狱
有四种角色
1.Observable可观察者，即被观察者
2.Observer观察者
3.Subscriber订阅事件
4.Subjects
Observables和Subjects是两个“生产”实体，Observers和Subscribers是两个“消费”实体
Observable和Observer通过subscribe()方法实现订阅关系，从而Observable可以在需要的时候发出事件来通知Observer
RxJava的基本实现
一.创建Observer
Observer=Subscriber
除了Observer接口之外，RxJava还内置一个实现了Observer的抽象类：Subscriber.
Subscriber对Observer接口进行了一些扩张，但他们的基本使用方式是完全一样的在RxJava的subscribe过程中，Observer也总是会先被转换成一个Subscriber再使用
1.onStart(),这是Subscriber增加的方法，它会在subscribe刚开始，而事件还未发送之前被调用，可以用于做一些准备工作，例如是数据的清零或重置，如果对准备工作的线程有要求可以使用doOnSubscribe()方法。
2.unsubscribe()这是subscriber所实现的另一个接口Subscription的方法，用于取消订阅在使用之前应该先用isUnsubscribed()先判断一下状态，要及时释放Observable持有的Subscriber的引用，不然会有内存溢出的风险
二.创建Observable
使用create()方法创建一个Observable,并为他定义事件触发规则
Observable observable = Obserable.create(new Observable.OnSubscribe){
@Override
public void call(Subscribersubscriber){
}
}
这里传入了一个OnSubscribe对象作为参数，OnSubscribe会被存储在返回的Observable对象中，他的作用相当于一个计划表，当Observable被订阅的时候，OnSubscribe的call方法会自动被调用。
Observable.just(T..)将传入的参数依次发送出来
Observable.from(T[])将传入的数组或Iterable拆分成具体对象后，依次发送出来
三.Subscribe（订阅）
创建了Observable和Observer之后，再用subscribe()方法将他们联结起来，整条链子就可以工作了
observable.subscribe(observer)
observable.subscribe(subscriber)
observable.subscribe(Subscriber)的内部实现
public Subscription subscribe(Subscriber subscriber){
subscriber.onStart();
onSubscribe.call(subscriber);
return subscriber；
}
Observable并不是在创建的时候就立即开始发送事件，而是在它被订阅的时候，即当subscribe()被执行的时候将传入的Subscriber作为Subscription返回，这是为了方便unSubscribe()
subscribe()还支持不完整定义的回调，RxJava会自动根据定义创建出Subscriber
Action1 onCompletedAction = new Action1(){
//onCompleted();
@Override
public void call(){
Log.d(tag,"completed");
}
};
observable.subscribe(onCompletedAction);
Action0 是 RxJava 的一个接口，它只有一个方法 call()，这个方法是无参无返回值的；由于onCompleted() 方法也是无参无返回值的，因此 Action0 可以被当成一个包装对象，将onCompleted() 的内容打包起来将自己作为一个参数传入 subscribe() 以实现不完整定义的回调。这样其实也可以看做将 onCompleted() 方法作为参数传进了 subscribe()，相当于其他某些语言中的『闭包』。
网友评论