SafeCompletableObserver

java.lang.Object
- io.reactivex.rxjava3.internal.observers.SafeCompletableObserver

All Implemented Interfaces:

CompletableObserver
```
public final class SafeCompletableObserver
extends java.lang.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) CompletableObserver downstream

(package private) boolean onSubscribeFailed

Constructor Summary

Constructors
Constructor Description

SafeCompletableObserver(CompletableObserver downstream)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`onComplete()`	Called once the deferred computation completes normally.
`void`	`onError(@NonNull java.lang.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 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - downstream
```
final CompletableObserver downstream
```
  - onSubscribeFailed
```
boolean onSubscribeFailed
```
- Constructor Detail
  - SafeCompletableObserver
```
public SafeCompletableObserver(CompletableObserver downstream)
```
- Method Detail
  - 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 java.lang.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