Rxjava2教程：Single、Completable、Maybe——简化版的Observable

Vicky 发布于2019-08-16 13:41 / 1965人阅读

摘要：只发射一条单一的数据，或者一条异常通知，不能发射完成通知，其中数据与通知只能发射一个。观察者可观察对象对应的观察者为方法等同于中的。没有用来处理完成通知的方法示例三发射完成通知示例四发射异常通知

在Rxjava2中，Observale和Flowable都是用来发射数据流的，但是，我们在实际应用中，很多时候，需要发射的数据并不是数据流的形式，而只是一条单一的数据，或者一条完成通知，或者一条错误通知。在这种情况下，我们再使用Observable或者Flowable就显得有点大材小用，于是，为了满足这种单一数据或通知的使用场景，便出现了Observable的简化版——Single、Completable、Maybe。

Single
只发射一条单一的数据，或者一条异常通知，不能发射完成通知，其中数据与通知只能发射一个。

Completable
只发射一条完成通知，或者一条异常通知，不能发射数据，其中完成通知与异常通知只能发射一个

Maybe
可发射一条单一的数据，以及发射一条完成通知，或者一条异常通知，其中完成通知和异常通知只能发射一个，发射数据只能在发射完成通知或者异常通知之前，否则发射数据无效。

示例一：Single发射单一数据

示例二：Single发射异常通知

SingleEmitter：Single的发射器
可观察对象Single的发射器接口SingleEmitter中，

1、方法void onSuccess(T t)用来发射一条单一的数据，且一次订阅只能调用一次，不同于Observale的发射器ObservableEmitter中的void onNext(@NonNull T value)方法，在一次订阅中，可以多次调用多次发射。
2、方法void onError(Throwable t)等同于ObservableEmitter中的void onError(@NonNull Throwable error)用来发射一条错误通知
3、SingleEmitter中没有用来发射完成通知的void onComplete()方法。
方法onSuccess与onError只可调用一个，若先调用onError则会导致onSuccess无效，若先调用onSuccess,则会抛出io.reactivex.exceptions.UndeliverableException异常。

SingleObserver：Single观察者
可观察对象Single对应的观察者为SingleObserver
方法void onSubscribe(Disposable d)等同于Observer中的void onSubscribe(Disposable d)。
方法void onSuccess(T t)类似于Observer中的onNext(T t)用来接收Single发的数据。
方法void onError(Throwable e)等同于Observer中的void onError(Throwable e)用来处理异常通知。
没有用来处理完成通知的方法void onComplete()

示例三：Completable发射完成通知

示例四：Completable发射异常通知

云服务器 GPU云服务器 Maybe Completable Observable single

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/72150.html

Rxjava2教程：Flowable背压支持

摘要：相对于最大的更新就是把对背压问题的处理逻辑从中抽取出来产生了新的可观察对象。由于基于发射的数据流，以及对数据加工处理的各操作符都添加了背压支持，附加了额外的逻辑，其运行效率要比慢得多。背压（backpressure）当上下游在不同的线程中，通过Observable发射，处理，响应数据流时，如果上游发射数据的速度快于下游接收处理数据的速度，这样对于那些没来得及处理的数据就会造成积压，这...

qianfeng 2019-08-16 13:41 评论0 收藏0
RxJava2.x源码解析（一）：订阅流程

摘要：现在网上已经有大量的源码分析文章，各种技术的都有。你完全可以写成下面的链式风格方法会最先被执行同样，为了便于理解，我会借用流里面经常用到的水流进行类比。该子类的命名是有规律可言的。现在网上已经有大量的源码分析文章，各种技术的都有。但我觉得很多文章对初学者并不友好，让人读起来云里雾里的，比源码还源码。究其原因，是根本没有从学习者的角度去分析。在自己完成了源码阅读之后，却忘记了自己是如何一步步提...

harryhappy 2019-05-23 17:32 评论0 收藏0
JAVA笔记 - 收藏集 - 掘金

摘要：动态代理个经纪人如何代理个明星掘金在代理模式女朋友这么漂亮，你缺经纪人吗中我们用宝强的例子介绍了静态代理模式的概念。掘金使用从头创建一个，这种方法比较简单。动态代理：1 个经纪人如何代理 N 个明星 - Android - 掘金在代理模式：女朋友这么漂亮，你缺经纪人吗？中我们用宝强的例子介绍了静态代理模式的概念。本来我的目的是通过大家耳熟能详的例子来加深理解，但是有些网友指责...

kamushin233 2019-08-16 10:37 评论0 收藏0