标签：自动 observer mdi 创建 通知 etc appcompat 特殊 super
首先导入依赖:
implementation ‘io.reactivex.rxjava2:rxjava:2.2.9‘
implementation ‘io.reactivex.rxjava2:rxandroid:2.1.1‘
Rxjava使用观察者模式实现异步操作,主要和Retrofit配合使用
RxJava 有四个基本概念：Observable (可观察者，即被观察者)、 Observer (观察者)、 subscribe (订阅)、事件。Observable 和 Observer 通过 subscribe() 方法实现订阅关系，从而 Observable 可以在需要的时候发出事件来通知 Observer。
与传统观察者模式不同， RxJava 的事件回调方法除了普通事件 onNext() （相当于 onClick() / onEvent()）之外，还定义了两个特殊的事件：onCompleted() 和 onError()。
onCompleted(): 事件队列完结。RxJava 不仅把每个事件单独处理，还会把它们看做一个队列。RxJava 规定，当不会再有新的 onNext() 发出时，需要触发 onCompleted() 方法作为标志。
onError(): 事件队列异常。在事件处理过程中出异常时，onError() 会被触发，同时队列自动终止，不允许再有事件发出。
在一个正确运行的事件序列中, onCompleted() 和 onError() 有且只有一个，并且是事件序列中的最后一个。需要注意的是，onCompleted() 和 onError() 二者也是互斥的，即在队列中调用了其中一个，就不应该再调用另一个。
public class MainActivity extends AppCompatActivity { Disposable mDisposable; protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); //建立连接 observable.subscribe(observer);//写法反了,可以理解为观察者订阅被观察者,被观察者(observable)也就是更新数据的一方,而观察者订阅了 是接受数据的一方, } //创建一个上游 被观察者 Observable： Observable<Integer> observable = Observable.create(new ObservableOnSubscribe<Integer>() { @Override public void subscribe(ObservableEmitter<Integer> emitter) throws Exception { emitter.onNext(1); emitter.onNext(2); emitter.onNext(3); emitter.onComplete(); } }); //创建一个下游 观察者Observer Observer<Integer> observer = new Observer<Integer>() { @Override public void onSubscribe(Disposable d) { Log.d("输出:", "subscribe");//开始订阅 } @Override public void onNext(Integer value) { Log.d("输出:", "" + value);//订阅下一个 } @Override public void onError(Throwable e) { Log.d("输出:", "error");//订阅出错 } @Override public void onComplete() { Log.d("输出:", "complete");//订阅完成 } }; }
observable.subscribe(observer);//写法反了,可以理解为观察者订阅被观察者,被观察者(observable)也就是更新数据的一方,而观察者订阅了 是接受数据的一方,就好像读者(观察者)订阅期刊(被观察者)一样,期刊
一旦更新会通知读者(我的理解)
标签：自动 observer mdi 创建 通知 etc appcompat 特殊 super
原文地址：https://www.cnblogs.com/Ocean123123/p/11017586.html
