RxJava-2-0 还没熟悉，RxJava-3-0 说来就来了！，安卓开发工具

• 将一些实验操作符推广到标准

• 从某些主题/处理器中删除 getValues()

• 删除 replay(Scheduler) 及其重载

• 删除 dematerialize()

• 删除 startWith(T|Iterable)

• 删除 as()

• 删除 Maybe.toSingle(T)

• 删除 Flowable.subscribe(4 args)

• 删除 Observable.subscribe(4 args)

• 删除 Single.toCompletable()

• 删除 Completable.blockingGet()

入门

1、添加依赖

implementation "io.reactivex.rxjava3:rxjava:3.0.0-RC0"

不好意思哦，还没看到 RxAndroid 出 3.0，这就很尴尬了...

2、一些概念

2.1、上流、下流

在 RxJava,数据以流的方式组织。也就是说，Rxjava 包括一个源的数据流，数据流后跟着消费者的零个到多个消费数据流步骤。

source.operator1().operator2().operator3().subscribe(consumer)

在上文代码中，对于 operator2 来说，在它前面叫做上流，在它后面的叫做下流。憋住，别笑，真的是下流来的。

2.2、流的对象

在 RxJava 的文档中，emission, emits, item, event, signal, data and message 都被认为在数据流中被传递的数据对象。

2.3、背压(Backpressure)

当数据流通过异步的步骤执行时，这些步骤的执行速度可能不一致。也就是说上流数据发送太快，下流没有足够的能力去处理。为了避免这种情况，一般要么缓存上流的数据，要么抛弃数据。但这种处理方式，有时会带来很大的问题。为此，RxJava 带来了 backpressure 的概念。背压是一种流量的控制步骤，在不知道上流还有多少数据的情形下控制内存的使用，表示它们还能处理多少数据。

支持背压的有 Flowable 类，不支持背压的有 Observable，Single, Maybe and Completable 类。

2.4 线程调度器（Schedulers）

对于我们 Android 开发来说，最喜欢的就是它简洁切换线程的操作。RxJava 通过调度器来方便线程的切换。

• Schedulers.computation(): 适合运行在密集计算的操作，大多数异步操作符使用该调度器。

• Schedulers.io():适合运行 I/0 和阻塞操作.

• Schedulers.single():适合需要单一线程的操作

• Schedulers.trampoline(): 适合需要顺序运行的操作

在不同平台还

《Android学习笔记总结+最新移动架构视频+大厂安卓面试真题+项目实战源码讲义》
浏览器打开：qq.cn.hn/FTe 免费领取

有不同的调度器，例如 Android 的主线程：AndroidSchedulers.mainThread()

Flowable.range(1, 10).observeOn(Schedulers.computation()).map(v -> v * v).blockingSubscribe(System.out::println);

2.5 基类

在 RxJava 3 可以发现有以下几个基类（跟 RxJava 2 是一致的吧）：

• io.reactivex.Flowable：发送 0 个 N 个的数据，支持 Reactive-Streams 和背压

• io.reactivex.Observable：发送 0 个 N 个的数据，不支持背压，

• io.reactivex.Single：只能发送单个数据或者一个错误

• io.reactivex.Completable：没有发送任何数据，但只处理 onComplete 和 onError 事件。

• io.reactivex.Maybe：能够发射 0 或者 1 个数据，要么成功，要么失败。

不建议再往下看了，建议点赞或收藏...

下文关于操作符内容太多了

等需要了，再来查阅

下班时间还是好好护发吧

My GitHub

精彩内容请看下回分解~（多种操作符代码详解）