public final Class SafeSingleObserver<T>

Class Inheritance

extends Object
implements SingleObserver<T>

All Implemented Interfaces

io.reactivex.rxjava3.core.SingleObserver

Type Parameters

Imports

Wraps another SingleObserver and catches exceptions thrown by its onSubscribe, onSuccess or onError methods despite the protocol forbids it.

Such exceptions are routed to the RxJavaPlugins#onError(Throwable) handler.

Field Summary

Modifier and Type	Field and Description
pack-priv final SingleObserver<? super T>	downstream
pack-priv boolean	onSubscribeFailed

Access	Constructor and Description
public	SafeSingleObserver(SingleObserver<? super T> downstream)

Modifier and Type	Method and Description
public void	onError(@NonNull Throwable e)
public void	onSubscribe(@NonNull Disposable d)
public void	onSuccess(T the item emitted by the `Single` t) Implements io.reactivex.rxjava3.core.SingleObserver.onSuccess. Notifies the `SingleObserver` with a single item and that the `Single` has finished sending push-based notifications.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

downstream	back to summary
pack-priv final SingleObserver<? super T> downstream

onSubscribeFailed	back to summary
pack-priv boolean onSubscribeFailed

SafeSingleObserver	back to summary
public SafeSingleObserver(SingleObserver<? super T> downstream)

onError	back to summary
public void onError(@NonNull Throwable e) Annotations @Override

onSubscribe	back to summary
public void onSubscribe(@NonNull Disposable d) Annotations @Override

onSuccess back to summary

onSuccess	back to summary
public void onSuccess(T t) Implements io.reactivex.rxjava3.core.SingleObserver.onSuccess. Doc from io.reactivex.rxjava3.core.SingleObserver.onSuccess. Notifies the `SingleObserver` with a single item and that the `Single` has finished sending push-based notifications. The `Single` will not call this method if it calls `onError`. Parameters t:T the item emitted by the `Single` Annotations @Override

public void onSuccess(T t)

Notifies the SingleObserver with a single item and that the Single has finished sending push-based notifications.

The Single will not call this method if it calls onError.

Parameters

Annotations