Class AbstractCompletableObserver

java.lang.Object
io.github.resilience4j.rxjava3.AbstractDisposable
io.github.resilience4j.rxjava3.AbstractCompletableObserver
All Implemented Interfaces:
io.reactivex.rxjava3.core.CompletableObserver, io.reactivex.rxjava3.disposables.Disposable
Direct Known Subclasses:
CompletableBulkhead.BulkheadCompletableObserver, CompletableCircuitBreaker.CircuitBreakerCompletableObserver, CompletableRateLimiter.RateLimiterCompletableObserver
public abstract class AbstractCompletableObserver extends AbstractDisposable implements io.reactivex.rxjava3.core.CompletableObserver

  • Field Details

    • downstreamObserver

      private final io.reactivex.rxjava3.core.CompletableObserver downstreamObserver

  • Constructor Details

    • AbstractCompletableObserver

      public AbstractCompletableObserver(io.reactivex.rxjava3.core.CompletableObserver downstreamObserver)

  • Method Details

    • hookOnSubscribe

      protected void hookOnSubscribe()
      Specified by:
      hookOnSubscribe in class AbstractDisposable

    • onComplete

      public void onComplete()
      Specified by:
      onComplete in interface io.reactivex.rxjava3.core.CompletableObserver

    • hookOnComplete

      protected abstract void hookOnComplete()

    • onError

      public void onError(Throwable e)
      Specified by:
      onError in interface io.reactivex.rxjava3.core.CompletableObserver

    • hookOnError

      protected abstract void hookOnError(Throwable e)