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

Vicky 發布于2019-08-16 13:41 / 1992人閱讀

摘要：只發射一條單一的數據，或者一條異常通知，不能發射完成通知，其中數據與通知只能發射一個。觀察者可觀察對象對應的觀察者為方法等同于中的。沒有用來處理完成通知的方法示例三發射完成通知示例四發射異常通知

在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

文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。

轉載請注明本文地址：http://m.specialneedsforspecialkids.com/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