观察者模式定义对象间的一种一对多的依赖关系,当被观察的对象发生变化时,所有的观察者都将得到通知进行相应的操作
过马路的时候我们都会看红绿灯,此时我们就是观察者,红绿灯由红变成绿的时候,行人和车辆观察到这个变化,开始穿越马路,这里的红绿灯变化就是可观察的对象
访问流程如下
Subject这里就是被观察的对象,Observer就是观察者
Disposable disposable = Observable.just(1).subscribe(new Consumer<Integer>() {
@Override
public void accept(Integer integer) throws Exception {
LOG.info("accept:{}", integer);
}
});
另值得注意的是 RxJava 是在订阅的时候就发送了数据
一个对象的改变需要需要周知到其它对象,做出相应的行为。但是却不知道具体有多少对象有待改变或根本不知道具体的对象是谁