Class AbstractSingleObserver<T>

java.lang.Object
io.github.resilience4j.rxjava3.AbstractDisposable
io.github.resilience4j.rxjava3.AbstractSingleObserver<T>
All Implemented Interfaces:
io.reactivex.rxjava3.core.SingleObserver<T>, io.reactivex.rxjava3.disposables.Disposable
Direct Known Subclasses:
SingleBulkhead.BulkheadSingleObserver, SingleCircuitBreaker.CircuitBreakerSingleObserver, SingleRateLimiter.RateLimiterSingleObserver
public abstract class AbstractSingleObserver<T> extends AbstractDisposable implements io.reactivex.rxjava3.core.SingleObserver<T>

  • Field Details

    • downstreamObserver

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

  • Constructor Details

    • AbstractSingleObserver

      public AbstractSingleObserver(io.reactivex.rxjava3.core.SingleObserver<? 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.SingleObserver<T>

    • hookOnError

      protected abstract void hookOnError(Throwable e)

    • onSuccess

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

    • hookOnSuccess

      protected abstract void hookOnSuccess(T value)