Rxjava2 笔记

文章目录
  1. 1. Backpressure (背压) 概念理解:
  2. 2. 数据类型
    1. 2.1. Obervable
    2. 2.2. Completable
    3. 2.3. Maybe
  3. 3. Flowable
  4. 4. Rxjava2 实现标准

Backpressure (背压) 概念理解:

当发送过来的数据速度快于处理数据的速度时,就需要用到 Backpressure ,Backpressure 是响应流控制的其中一个方案。
这里引用了 大神 Jake Warton 的一个例子,https://realm.io/cn/news/gotocph-jake-wharton-exploring-rxjava2-android/

数据类型

  1. Observable (不支持 Backpressure)
  2. Flowable (支持 Backpressure)

Obervable

Single 是 Observable 三个子集中的其中一个子集:只返回一个结果,要么是正确的结果数据,要么就是抛出异常,没有别的。与 scaler 方法类似,只不过 Single 是响应式,scaler 是命令式。

Completable

错误时抛出异常,成功时没有任何返回。

Maybe

同 Single,再加上一个可能,结果可能返回是空值

Flowable

在 Flwable 下的操作符强制支持背压

Rxjava2 实现标准

Rxjava2 遵循了 Reactive Streams Specification (响应流)规范,主要体现在四个基础接口
1 Publisher
2 Subscriber
3 Subscription
4 Processor