Class AbstractMaybeObserver<T>

java.lang.Object
io.github.resilience4j.rxjava3.AbstractDisposable
io.github.resilience4j.rxjava3.AbstractMaybeObserver<T>
All Implemented Interfaces:
io.reactivex.rxjava3.core.MaybeObserver<T>, io.reactivex.rxjava3.disposables.Disposable
Direct Known Subclasses:
MaybeBulkhead.BulkheadMaybeObserver, MaybeCircuitBreaker.CircuitBreakerMaybeObserver, MaybeRateLimiter.RateLimiterMaybeObserver
public abstract class AbstractMaybeObserver<T> extends AbstractDisposable implements io.reactivex.rxjava3.core.MaybeObserver<T>

  • Field Details

    • downstreamObserver

      private final io.reactivex.rxjava3.core.MaybeObserver<? super T> downstreamObserver

  • Constructor Details

    • AbstractMaybeObserver

      public AbstractMaybeObserver(io.reactivex.rxjava3.core.MaybeObserver<? super T> downstreamObserver)

  • Method Details

    • hookOnSubscribe

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

    • onError

      public void onError(Throwable e)
      Specified by:
      onError in interface io.reactivex.rxjava3.core.MaybeObserver<T>

    • onComplete

      public void onComplete()
      Specified by:
      onComplete in interface io.reactivex.rxjava3.core.MaybeObserver<T>

    • hookOnComplete

      protected abstract void hookOnComplete()

    • hookOnError

      protected abstract void hookOnError(Throwable e)

    • onSuccess

      public void onSuccess(T value)
      Specified by:
      onSuccess in interface io.reactivex.rxjava3.core.MaybeObserver<T>

    • hookOnSuccess

      protected abstract void hookOnSuccess(T value)