Android 异步操作库 RxJava

RxJava概述

RxJava 是一种响应式编程，来创建基于事件的异步操作库。基于事件流的链式调用、逻辑清晰简洁。
RxJava 我的理解是将事件从起点（上游）流向终点（下游），中间有很多卡片对数据进操作并传递，每个卡片获取上一个卡片传递下来的结果然后对事件进行处理然后将结果传递给下一个卡片，这样事件就从起点通过卡片一次次传递直到流向终点。
RxJava观察者模式
传统观察者是一个被观察者多过观察者，当被观察者发生改变时候及时通知所有观察者
RXjava是一个观察者多个被观察者，被观察者像链条一样串起来，数据在被观察者之间朝着一个方向传递，直到传递给观察者 。
RxJava原理理解：被观察者通过订阅将事件按顺序依次传递给观察者，

https://github.com/ReactiveX/RxJava

总结：

1. RxJava 是一个 基于事件流、实现异步操作的库
2. 作用：实现异步操作，类似于 Android中的 AsyncTask 、Handler作用
3. 特点：由于 RxJava的使用方式是基于事件流的链式调用，所以使得 RxJava逻辑简洁、实现优雅、
   使用简单

示例用法

在主线程上观察
在 Android 上处理异步任务时最常见的操作之一是在主线程上观察任务的结果或结果。使用 vanilla Android，这通常可以通过 AsyncTask. Observable相反，使用 RxJava 时，您将在主线程上声明要被观察到：

Observable.just("one", "two", "three", "four", "five").subscribeOn(Schedulers.newThread()).observeOn(AndroidSchedulers.mainThread()).subscribe(/* an Observer */);

这将Observable在新线程上执行，并onNext在主线程上发出结果。

观察任意循环器
前面的示例只是一个更一般概念的专门化：将异步通信绑定到 Android 消息循环，或Looper. 为了观察Observable任意 一个，通过调用Looper创建一个关联：SchedulerAndroidSchedulers.from

Looper backgroundLooper = // ...
Observable.just("one", "two", "three", "four", "five").observeOn(AndroidSchedulers.from(backgroundLooper)).subscribe(/* an Observer */)

这将在新线程上执行 Observable 并onNext在任何正在运行的线程上发出结果backgroundLooper。

相关参考

https://blog.csdn.net/yzwfeng/article/details/123493988