观察者模式:当一个对象发生变化时,依赖它的所有对象都会被通知并且会自动更新
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(),相当于其他某些语言中的『闭包』。