Class AbstractObserver<T>

java.lang.Object
io.github.resilience4j.rxjava3.AbstractDisposable
io.github.resilience4j.rxjava3.AbstractObserver<T>
All Implemented Interfaces:
io.reactivex.rxjava3.core.Observer<T>, io.reactivex.rxjava3.disposables.Disposable
Direct Known Subclasses:
ObserverBulkhead.BulkheadObserver, ObserverCircuitBreaker.CircuitBreakerObserver, ObserverRateLimiter.RateLimiterObserver
public abstract class AbstractObserver<T> extends AbstractDisposable implements io.reactivex.rxjava3.core.Observer<T>

  • Field Details

    • eventWasEmitted

      protected final AtomicBoolean eventWasEmitted

    • downstreamObserver

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

  • Constructor Details

    • AbstractObserver

      public AbstractObserver(io.reactivex.rxjava3.core.Observer<? super T> downstreamObserver)

  • Method Details

    • hookOnSubscribe

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

    • onNext

      public void onNext(T item)
      Specified by:
      onNext in interface io.reactivex.rxjava3.core.Observer<T>

    • hookOnNext

      protected void hookOnNext(T value)

    • onError

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

    • hookOnError

      protected abstract void hookOnError(Throwable e)

    • onComplete

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

    • hookOnComplete

      protected abstract void hookOnComplete()