Class CompletablePeek.CompletableObserverImplementation

java.lang.Object
io.reactivex.rxjava3.internal.operators.completable.CompletablePeek.CompletableObserverImplementation
All Implemented Interfaces:
CompletableObserver, Disposable
Enclosing class:
CompletablePeek

final class CompletablePeek.CompletableObserverImplementation extends Object implements CompletableObserver, Disposable
  • Field Details

  • Constructor Details

    • CompletableObserverImplementation

      CompletableObserverImplementation(CompletableObserver downstream)
  • 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
    • doAfter

      void doAfter()
    • dispose

      public void dispose()
      Description copied from interface: Disposable
      Dispose the resource, the operation should be idempotent.
      Specified by:
      dispose in interface Disposable
    • isDisposed

      public boolean isDisposed()
      Description copied from interface: Disposable
      Returns true if this resource has been disposed.
      Specified by:
      isDisposed in interface Disposable
      Returns:
      true if this resource has been disposed