Rxjava2入門教程六:Single呜笑、Completable、Maybe——簡化版的Observable

如需下載源碼彻犁,請訪問
https://github.com/fengchuanfang/Rxjava2Tutorial
文章原創(chuàng)叫胁,轉(zhuǎn)載請注明出處:
Rxjava2入門教程六:Single、Completable汞幢、Maybe——簡化版的Observable


在Rxjava2中驼鹅,Observale和Flowable都是用來發(fā)射數(shù)據(jù)流的,但是森篷,我們在實際應(yīng)用中输钩,很多時候,需要發(fā)射的數(shù)據(jù)并不是數(shù)據(jù)流的形式仲智,而只是一條單一的數(shù)據(jù)买乃,或者一條完成通知,或者一條錯誤通知钓辆。在這種情況下剪验,我們再使用Observable或者Flowable就顯得有點大材小用哼绑,于是,為了滿足這種單一數(shù)據(jù)或通知的使用場景碉咆,便出現(xiàn)了Observable的簡化版——Single、Completable蛀恩、Maybe疫铜。

Single

只發(fā)射一條單一的數(shù)據(jù),或者一條異常通知双谆,不能發(fā)射完成通知壳咕,其中數(shù)據(jù)與通知只能發(fā)射一個。

Completable

只發(fā)射一條完成通知顽馋,或者一條異常通知谓厘,不能發(fā)射數(shù)據(jù),其中完成通知與異常通知只能發(fā)射一個

Maybe

可發(fā)射一條單一的數(shù)據(jù)寸谜,以及發(fā)射一條完成通知竟稳,或者一條異常通知,其中完成通知和異常通知只能發(fā)射一個熊痴,發(fā)射數(shù)據(jù)只能在發(fā)射完成通知或者異常通知之前他爸,否則發(fā)射數(shù)據(jù)無效。

示例一:Single發(fā)射單一數(shù)據(jù)

singleDemo1.jpg

示例二:Single發(fā)射異常通知

singleDemo2.jpg

SingleEmitter:Single的發(fā)射器

可觀察對象Single的發(fā)射器接口SingleEmitter中果善,

1诊笤、方法void onSuccess(T t)用來發(fā)射一條單一的數(shù)據(jù),且一次訂閱只能調(diào)用一次巾陕,不同于Observale的發(fā)射器ObservableEmitter中的void onNext(@NonNull T value)方法讨跟,在一次訂閱中,可以多次調(diào)用多次發(fā)射鄙煤。
2晾匠、方法void onError(Throwable t)等同于ObservableEmitter中的void onError(@NonNull Throwable error)用來發(fā)射一條錯誤通知
3、SingleEmitter中沒有用來發(fā)射完成通知的void onComplete()方法梯刚。
方法onSuccess與onError只可調(diào)用一個混聊,若先調(diào)用onError則會導(dǎo)致onSuccess無效,若先調(diào)用onSuccess,則會拋出io.reactivex.exceptions.UndeliverableException異常乾巧。

SingleObserver:Single觀察者

可觀察對象Single對應(yīng)的觀察者為SingleObserver

SingleObserver.jpg

方法void onSubscribe(Disposable d)等同于Observer中的void onSubscribe(Disposable d)句喜。
方法void onSuccess(T t)類似于Observer中的onNext(T t)用來接收Single發(fā)的數(shù)據(jù)。
方法void onError(Throwable e)等同于Observer中的void onError(Throwable e)用來處理異常通知沟于。
沒有用來處理完成通知的方法void onComplete()

示例三:Completable發(fā)射完成通知

completableDemo1.jpg

示例四:Completable發(fā)射異常通知

completableDemo2.jpg

CompletableEmitter:Completable的發(fā)射器

可觀察對象Completable的發(fā)射器接口CompletableEmitter中
1咳胃、方法onComplete()等同于Observale的發(fā)射器ObservableEmitter中的onComplete(),用來發(fā)射完成通知旷太。
2展懈、方法onError(Throwable e)等同于ObservableEmitter中的onError(Throwable e)销睁,用來發(fā)射異常通知。
方法onComplete與onError只可調(diào)用一個存崖,若先調(diào)用onError則會導(dǎo)致onComplete無效冻记,若先調(diào)用onComplete,則會拋出io.reactivex.exceptions.UndeliverableException異常。

CompletableObserver:Completable的觀察者

可觀察對象Completable對應(yīng)的觀察者為CompletableObserver

completableObserver.jpg

其中的三個方法均等同于Observer中的對應(yīng)的方法来惧,CompletableObserver中沒有用來發(fā)射數(shù)據(jù)的方法冗栗。

示例五:Maybe發(fā)射單一數(shù)據(jù)和完成通知

maybeDemo1.jpg

示例六:Maybe發(fā)射單一數(shù)據(jù)和異常通知

maybeDemo2.jpg

MaybeEmitter:Maybe的發(fā)射器

可觀察對象Maybe的發(fā)射器接口MaybeEmitter中
1、方法void onSuccess(T t)用來發(fā)射一條單一的數(shù)據(jù)供搀,且一次訂閱只能調(diào)用一次隅居,不同于Observale的發(fā)射器ObservableEmitter中的void onNext(@NonNull T value)方法,在一次訂閱中葛虐,可以多次調(diào)用多次發(fā)射胎源。
2、方法void onError(Throwable t)等同于ObservableEmitter中的void onError(@NonNull Throwable error);用來發(fā)射一條錯誤通知
3屿脐、方法onComplete()等同于Observale的發(fā)射器ObservableEmitter中的onComplete()涕蚤,用來發(fā)射完成通知。
方法onComplete與onError只可調(diào)用一個的诵,若先調(diào)用onError則會導(dǎo)致onComplete無效赞季,若先調(diào)用onComplete,則會拋出io.reactivex.exceptions.UndeliverableException異常。
方法onSuccess必須在方法onComplete或onError之前調(diào)用奢驯,否則會導(dǎo)致方法onSuccess調(diào)用無效申钩。

MaybeObserver:Maybe的觀察者

可觀察對象Maybe對應(yīng)的觀察者為MaybeObserver

MaybeObserver.jpg

方法void onSubscribe(Disposable d)等同于Observer中的void onSubscribe(Disposable d)。
方法void onSuccess(T t)類似于Observer中的onNext(T t)用來接收Single發(fā)的數(shù)據(jù)瘪阁。
方法void onError(Throwable e)等同于Observer中的void onError(Throwable e)用來處理異常通知撒遣。
方法void onComplete()等同于Observer中的void onComplete()用來接收完成通知。
上一篇:Rxjava2入門教程五:Flowable背壓支持——幾乎可以說是對Flowable最全面而詳細的講解

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末管跺,一起剝皮案震驚了整個濱河市义黎,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌豁跑,老刑警劉巖廉涕,帶你破解...
    沈念sama閱讀 218,941評論 6 508
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場離奇詭異艇拍,居然都是意外死亡狐蜕,警方通過查閱死者的電腦和手機,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 93,397評論 3 395
  • 文/潘曉璐 我一進店門卸夕,熙熙樓的掌柜王于貴愁眉苦臉地迎上來层释,“玉大人,你說我怎么就攤上這事快集」备幔” “怎么了廉白?”我有些...
    開封第一講書人閱讀 165,345評論 0 356
  • 文/不壞的土叔 我叫張陵,是天一觀的道長乖寒。 經(jīng)常有香客問我猴蹂,道長,這世上最難降的妖魔是什么楣嘁? 我笑而不...
    開封第一講書人閱讀 58,851評論 1 295
  • 正文 為了忘掉前任磅轻,我火速辦了婚禮,結(jié)果婚禮上马澈,老公的妹妹穿的比我還像新娘。我一直安慰自己弄息,他們只是感情好痊班,可當我...
    茶點故事閱讀 67,868評論 6 392
  • 文/花漫 我一把揭開白布。 她就那樣靜靜地躺著摹量,像睡著了一般涤伐。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上缨称,一...
    開封第一講書人閱讀 51,688評論 1 305
  • 那天凝果,我揣著相機與錄音,去河邊找鬼睦尽。 笑死器净,一個胖子當著我的面吹牛,可吹牛的內(nèi)容都是我干的当凡。 我是一名探鬼主播山害,決...
    沈念sama閱讀 40,414評論 3 418
  • 文/蒼蘭香墨 我猛地睜開眼,長吁一口氣:“原來是場噩夢啊……” “哼沿量!你這毒婦竟也來了浪慌?” 一聲冷哼從身側(cè)響起,我...
    開封第一講書人閱讀 39,319評論 0 276
  • 序言:老撾萬榮一對情侶失蹤朴则,失蹤者是張志新(化名)和其女友劉穎权纤,沒想到半個月后,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體乌妒,經(jīng)...
    沈念sama閱讀 45,775評論 1 315
  • 正文 獨居荒郊野嶺守林人離奇死亡汹想,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 37,945評論 3 336
  • 正文 我和宋清朗相戀三年,在試婚紗的時候發(fā)現(xiàn)自己被綠了撤蚊。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片欧宜。...
    茶點故事閱讀 40,096評論 1 350
  • 序言:一個原本活蹦亂跳的男人離奇死亡,死狀恐怖拴魄,靈堂內(nèi)的尸體忽然破棺而出冗茸,到底是詐尸還是另有隱情席镀,我是刑警寧澤,帶...
    沈念sama閱讀 35,789評論 5 346
  • 正文 年R本政府宣布夏漱,位于F島的核電站豪诲,受9級特大地震影響,放射性物質(zhì)發(fā)生泄漏挂绰。R本人自食惡果不足惜屎篱,卻給世界環(huán)境...
    茶點故事閱讀 41,437評論 3 331
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望葵蒂。 院中可真熱鬧交播,春花似錦、人聲如沸践付。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,993評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽永高。三九已至隧土,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間命爬,已是汗流浹背曹傀。 一陣腳步聲響...
    開封第一講書人閱讀 33,107評論 1 271
  • 我被黑心中介騙來泰國打工, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留饲宛,地道東北人皆愉。 一個月前我還...
    沈念sama閱讀 48,308評論 3 372
  • 正文 我出身青樓,卻偏偏與公主長得像艇抠,于是被迫代替她去往敵國和親亥啦。 傳聞我的和親對象是個殘疾皇子,可洞房花燭夜當晚...
    茶點故事閱讀 45,037評論 2 355

推薦閱讀更多精彩內(nèi)容