CompletableTimeout.DisposeTask.DisposeObserver

java.lang.Object

io.reactivex.rxjava3.internal.operators.completable.CompletableTimeout.DisposeTask.DisposeObserver

All Implemented Interfaces:: CompletableObserver

Enclosing class:: CompletableTimeout.DisposeTask

final class CompletableTimeout.DisposeTask.DisposeObserver extends Object implements CompletableObserver

Constructor Summary

Constructors

Constructor

Description

DisposeObserver()
Method Summary

Modifier and Type

Method

Description

void

onComplete()

Called once the deferred computation completes normally.

void

onError(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

Constructor Details
- DisposeObserver
  
  DisposeObserver()
Method Details
- 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
- onError
  
  public void onError(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