RxJava之Observables类型理解

RxJava Observables

Observable — Operator — Observer

Observable就像一个发声的扬声器。它会执行一些任务并发射(emit)一些值。
Operator就像一个翻译机,将数据从一种形式翻译或者修改为另一种形式。
Observer获得这些值。

RxJava中的Observables类型

以下即为RxJava中不同的Observables类型

  • Observable
  • Flowable
  • Single
  • Maybe
  • Completable

既然有不同的Observables类型,随之也有不同的Observers类型。如下:

  • Obeserver
  • SingleObserver
  • MaybeObserver
  • CompletableObserver

现在就让我们来看看他们之间的区别和如何选择。

Observable <> Observer

此为最简单的Observable,可以发射不止一个值。
举个栗子:比方说你正在下载一个文件,报告当前的下载进度。此时将会发射不止一个值。

创建一个简单的Observable

对应的Observer

Flowable <> Observer

Flowable 用于当Obserable发射很多的值时而Observer消费不过来的时候。
这种情况下,Observable需要基于某种策略忽略一些值,否则将会抛出异常。
Flowable Observable会通过某种策略来处理异常。
这个策略为BackPressureStrategy,异常为MissingBackPressureException

创建一个Flowable Observable

与创建一个普通的Observable类似,你可以使用Flowable.create()来创建一个Flowable。

对应Flowable Observable的Observer

与普通的Observer基本一样。

Single <> SingleObserver

SIngle用于当Observable只需要发射一次值,比如网络请求的响应的时候。

创建一个Single Observable

对应Single Observable的SingleObserver

Maybe <> MaybeObserver

Maybe 用于当Observable发射一个值或没有值的时候。

创建一个 Maybe Observable

对应Maybe Observable的MaybeObserver

Completable <> CompletableObserver

Completable 用于Observable完成某个任务而不发射任何值得时候。

创建一个 Completable Observable

对应Completable Observable的CompletableObserver

好啦,现在你该知道如何根据你的场景来选择哪一个Observable啦吧。

完整的Rxjava教程

RxJava是关于Reactive Extensions的java 虚拟机实现,它已成为Android开发的一项最重要的技能。
翻译自Understanding Types Of Observables In RxJava

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

友情链接更多精彩内容