CompletableOnErrorComplete.OnError

java.lang.Object
- io.reactivex.rxjava3.internal.operators.completable.CompletableOnErrorComplete.OnError

All Implemented Interfaces:: CompletableObserver

Enclosing class:: CompletableOnErrorComplete

static final class CompletableOnErrorComplete.OnError
extends java.lang.Object
implements CompletableObserver

Field Summary

Fields
Modifier and Type Field Description

private CompletableObserver downstream

private Predicate<? super java.lang.Throwable> predicate

Constructor Summary

Constructors
Constructor Description

OnError(CompletableObserver observer, Predicate<? super java.lang.Throwable> predicate)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`onComplete()`	Called once the deferred computation completes normally.
`void`	`onError(java.lang.Throwable e)`	Called once if the deferred computation 'throws' an exception.
`void`	`onSubscribe(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
```
private final CompletableObserver downstream
```
  - predicate
```
private final Predicate<? super java.lang.Throwable> predicate
```
- Constructor Detail
  - OnError
```
OnError(CompletableObserver observer,
        Predicate<? super java.lang.Throwable> predicate)
```
- Method Detail
  - onComplete
```
public void onComplete()
```
    Description copied from interface: CompletableObserver
    
    Called once the deferred computation completes normally.
    
    Specified by:
    
    onComplete in interface CompletableObserver
  - onError
```
public void onError(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.
  - onSubscribe
```
public void onSubscribe(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