Class SafeCompletableObserver

java.lang.Object

io.reactivex.rxjava3.internal.observers.SafeCompletableObserver

All Implemented Interfaces:

CompletableObserver

public final class SafeCompletableObserver
extends Object
implements CompletableObserver

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

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

Since:

3.0.0

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final CompletableObserver	downstream
(package private) boolean	onSubscribeFailed

Constructor Summary

Constructors

Constructor	Description
SafeCompletableObserver(CompletableObserver downstream)

Method Summary

Modifier and Type	Method	Description
void	onComplete()	Called once the deferred computation completes normally.
void	onError(@NonNull Throwable e)	Called once if the deferred computation 'throws' an exception.
void	onSubscribe(@NonNull Disposable d)	Called once by the Completable to set a Disposable on this instance which then can be used to cancel the subscription at any time.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

downstream

final CompletableObserver downstream

onSubscribeFailed

boolean onSubscribeFailed

Constructor Details

SafeCompletableObserver

public SafeCompletableObserver(CompletableObserver downstream)

Method Details

onSubscribe

public void onSubscribe(@NonNull
 @NonNull Disposable d)

Description copied from interface: CompletableObserver

Called once by the Completable to set a Disposable on this instance which then can be used to cancel the subscription at any time.

Specified by:

onSubscribe in interface CompletableObserver

Parameters:

d - the Disposable instance to call dispose on for cancellation, not null

onError

public void onError(@NonNull
 @NonNull Throwable e)

Description copied from interface: CompletableObserver

Called once if the deferred computation 'throws' an exception.

Specified by:

onError in interface CompletableObserver

Parameters:

e - the exception, not null.

onComplete

public void onComplete()

Description copied from interface: CompletableObserver

Called once the deferred computation completes normally.

Specified by:

onComplete in interface CompletableObserver