如需下載源碼彻犁,請訪問
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ù)
示例二:Single發(fā)射異常通知
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
方法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ā)射完成通知
示例四:Completable發(fā)射異常通知
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
其中的三個方法均等同于Observer中的對應(yīng)的方法来惧,CompletableObserver中沒有用來發(fā)射數(shù)據(jù)的方法冗栗。
示例五:Maybe發(fā)射單一數(shù)據(jù)和完成通知
示例六:Maybe發(fā)射單一數(shù)據(jù)和異常通知
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
方法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最全面而詳細的講解