Rxjava入门第一篇，搞定 Observer 与 Observable 之间的关系

百度百科原文翻译：
RxJava - JVM响应式扩展Reactive Extensions 用于使用Java VM的可观察序列编写异步和基于事件的程序的库。
它扩展了观察者模式以支持数据和/或事件序列，并增加了运算符，使您可以声明性地组合序列，同时抽象出对低级线程，同步，线程安全性，并发数据结构和非线程等事物的关注阻塞I / O

安装 app下面build.gradle 加入两行，然后编译

implementation 'io.reactivex:rxjava:1.1.1'
implementation 'io.reactivex:rxandroid:1.0.1'

介绍

观察者：Observer
被观察者：Observable
两者创建关联：subscribe()

观察者

创建一个观察者(名字很生疏难理解，举例说明)
- eg.
- 观察者小明打算出去走走，多看看外面的世界

Observer<String> observer = new Observer<String>() {
    @Override //小明的第一个反应，采取某种行动， 或者心潮澎湃 ，执行 onCompleted方法
    public void onCompleted() {
        LogUtils.e("Completed");
    }
    @Override //小明的第二个反应，Pass 内心毫无波澜 下一位  ,执行 onNext方法
    public void onError(Throwable e) {
        LogUtils.e("Error");
    }
    @Override //小明的第三个反应，Oh..NO  MyGod  WC ... 执行 onError 方法
    public void onNext(String s) {
        LogUtils.e(s);
    }
};

被观察者

创建一个被观察者(聪明且百变的被观察者)
- 此被观察者具有变化能力，能变成三种形态
  - A 一个漂亮的小姐姐
  - B 一个平淡无奇如同路人一样的人
  - C 一个猥琐的伪娘
- 创建被观察者小花


Observable observable1 = Observable.create(new Observable.OnSubscribe<String>() {
    @Override
    public void call(Subscriber<? super String> subscriber) {
        subscriber.onCompleted(); //被观察者小花变成A形态
    }
});
Observable observable1 = Observable.create(new Observable.OnSubscribe<String>() {
    @Override
    public void call(Subscriber<? super String> subscriber) {
        subscriber.onNext("Hello"); //被观察者小花变成B形态
    }
});
Observable observable1 = Observable.create(new Observable.OnSubscribe<String>() {
    @Override
    public void call(Subscriber<? super String> subscriber) {
        subscriber.onError("Wrold");//被观察者小花变成C形态
    }
});

最关键的一步(创建小明Observer和小花Observable的关系)
- 让小花和小明一起走在林荫道上

observable1.subscribe(observer);

整体串起来是这样

小明来到了外面的世界，走在林荫道上
- 正要仔细观察世界，遇到了小花(subscribe)

小花变成A形态(一个漂亮的小姐姐)

小明决定采取某种行动，或者心潮澎湃，然后执行 onCompleted方法

小花变成B形态(一个平淡无奇如同路人一样的人)

小明....Pass 下一位然后执行 onNext方法

小花变成C形态(一个猥琐的伪娘)

小明 Oh..NO MyGod WC ... CCC 执行 onError 方法

总结

关键点是两者需要发生连接，如果没有连接，rxjava就没用了