在Rxjava2中，Observale和Flowable都是用來發射資料流的，但是，我們在實際應用中，很多時候，需要發射的資料並不是資料流的形式，而只是一條單一的資料，或者一條完成通知，或者一條錯誤通知。在這種情況下，我們再使用Observable或者Flowable就顯得有點大材小用，於是，為了滿足這種單一資料或通知的使用場景，便出現了Observable的簡化版——Single、Completable、Maybe。

Single

只發射一條單一的資料，或者一條異常通知，不能發射完成通知，其中資料與通知只能發射一個。

Completable

只發射一條完成通知，或者一條異常通知，不能發射資料，其中完成通知與異常通知只能發射一個

Maybe

可發射一條單一的資料，以及發射一條完成通知，或者一條異常通知，其中完成通知和異常通知只能發射一個，發射資料只能在發射完成通知或者異常通知之前，否則發射資料無效。

示例一：Single發射單一資料

singleDemo1.jpg

示例二：Single發射異常通知

singleDemo2.jpg

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

SingleObserver.jpg

方法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發射完成通知

completableDemo1.jpg

示例四：Completable發射異常通知

completableDemo2.jpg

CompletableEmitter：Completable的發射器

可觀察物件Completable的發射器介面CompletableEmitter中
1、方法onComplete()等同於Observale的發射器ObservableEmitter中的onComplete()，用來發射完成通知。
2、方法onError(Throwable e)等同於ObservableEmitter中的onError(Throwable e)，用來發射異常通知。
方法onComplete與onError只可呼叫一個，若先呼叫onError則會導致onComplete無效，若先呼叫onComplete,則會丟擲io.reactivex.exceptions.UndeliverableException異常。

CompletableObserver：Completable的觀察者

可觀察物件Completable對應的觀察者為CompletableObserver

completableObserver.jpg

其中的三個方法均等同於Observer中的對應的方法，CompletableObserver中沒有用來發射資料的方法。

示例五：Maybe發射單一資料和完成通知

maybeDemo1.jpg

示例六：Maybe發射單一資料和異常通知

maybeDemo2.jpg

MaybeEmitter：Maybe的發射器

可觀察物件Maybe的發射器介面MaybeEmitter中
1、方法void onSuccess(T t)用來發射一條單一的資料，且一次訂閱只能呼叫一次，不同於Observale的發射器ObservableEmitter中的void onNext(@NonNull T value)方法，在一次訂閱中，可以多次呼叫多次發射。
2、方法void onError(Throwable t)等同於ObservableEmitter中的void onError(@NonNull Throwable error);用來發射一條錯誤通知
3、方法onComplete()等同於Observale的發射器ObservableEmitter中的onComplete()，用來發射完成通知。
方法onComplete與onError只可呼叫一個，若先呼叫onError則會導致onComplete無效，若先呼叫onComplete,則會丟擲io.reactivex.exceptions.UndeliverableException異常。
方法onSuccess必須在方法onComplete或onError之前呼叫，否則會導致方法onSuccess呼叫無效。

MaybeObserver：Maybe的觀察者

可觀察物件Maybe對應的觀察者為MaybeObserver

MaybeObserver.jpg

方法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()等同於Observer中的void onComplete()用來接收完成通知。

作者：馮豐楓
連結：https://www.jianshu.com/p/66a55abbadef
來源：簡書
簡書著作權歸作者所有，任何形式的轉載都請聯絡作者獲得授權並註明出處。