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