Top Description Fields Constructors Methods
io.reactivex.rxjava3.internal.observers

public final Class SafeCompletableObserver

extends Object
implements CompletableObserver
Class Inheritance
All Implemented Interfaces
io.reactivex.rxjava3.core.CompletableObserver
Imports
io.reactivex.rxjava3.annotations.NonNull, io.reactivex.rxjava3.core.CompletableObserver, io.reactivex.rxjava3.disposables.Disposable, io.reactivex.rxjava3.exceptions.*, io.reactivex.rxjava3.plugins.RxJavaPlugins
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

Modifier and TypeField and Description
pack-priv final CompletableObserver
downstream

pack-priv boolean
onSubscribeFailed

Constructor Summary

AccessConstructor and Description
public
SafeCompletableObserver(CompletableObserver downstream)

Method Summary

Modifier and TypeMethod and Description
public void
onComplete()

Implements io.reactivex.rxjava3.core.CompletableObserver.onComplete.

Called once the deferred computation completes normally.
public void
onError(@NonNull Throwable e)

public void
onSubscribe(@NonNull Disposable d)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

downstreamback to summary
pack-priv final CompletableObserver downstream
onSubscribeFailedback to summary
pack-priv boolean onSubscribeFailed

Constructor Detail

SafeCompletableObserverback to summary
public SafeCompletableObserver(CompletableObserver downstream)

Method Detail

onCompleteback to summary
public void onComplete()

Implements io.reactivex.rxjava3.core.CompletableObserver.onComplete.

Doc from io.reactivex.rxjava3.core.CompletableObserver.onComplete.

Called once the deferred computation completes normally.

Annotations
@Override
onErrorback to summary
public void onError(@NonNull Throwable e)
Annotations
@Override
onSubscribeback to summary
public void onSubscribe(@NonNull Disposable d)
Annotations
@Override