注册

去登录

解锁回答区域

若你登陆，将永久解锁；
若未登录，仅本机解锁。

解锁回答区域

鸿洋 2021-01-03 20:34 收藏

RxJava 算是现在 Android 中非常常用的一个开源库了，例如和 retrofit 配合完成网络请求封装。

我大概看到以下几个关键词都能完成网络请求的发送：

@GET("query")
Observable<Article> getArticle(...)

其中Observable可以替换为Flowable,Single,Maybe，问题来了：

最近有点忙，加上问答有点难想，但是还是准备保证下更下频率，工作日周 2-3 问，大家监督。

上一问下一问有新回答请提醒我请先登录...

xianph 2021-01-07 11:19

RxJava 五种“生产者”的区别：

Observable ，可多次发送事件，直到 onComplete 或 onError 被调用结束订阅。
Flowable ，和 Observable 一样。并且可以处理背压（下游处理速度比上游发送速度要慢）。
Single ，单次发送事件（onSuccess、onError），发完即结束订阅。
Completable ，单次发送事件（onError、onComplete），发完即结束订阅。
Maybe ，单次发送事件（onSuccess、onError、onComplete），发完即结束订阅。相当于 Completable 和 Single 结合。

根据五种“生产者”的特性，合理的场景使用：

总结：

一般来说，我们一个接口，只是一次请求一次返回，所以我们通常使用 Single 与 Retrofit 是更为合理。

即使返回结果需要再次处理，也可以使用操作符在各种“生产者”之间相互转换（toSingle、toObservable、toFlowable、toMaybe、toCompletable），使用对应的操作符。

逮虾户 2020-12-28 18:42

我查了下资料，这些构造一个Rxjava流的的差别就在于其中的Emitter不一样，其中emitter负责串联上下游流。

举个例子Observable可以发送多个数据源，还有就是必须要有一个complete，否则不会取消。

Flowable则不一样，负责处理背压情况，背压出现在输入流的输入速度远远大于接受流的处理速度，这种时候就要有类似线程池内的异常Handler处理。

而Single 则因为Emitter只需要发射一个Next就可以继续向下执行了，而不需要像Observable一样可以多次调用next，最后需要执行complete。

其中还有一种Completableis 基本和Single一样，只是emitter只需要发射complete方法就行了。

最后Maybe 则像是一种single和Completableis的结合体，他的next方法允许发射一个null或者一个对象。