Class SingleRateLimiter.RateLimiterSingleObserver

java.lang.Object

io.github.resilience4j.rxjava3.AbstractDisposable

io.github.resilience4j.rxjava3.AbstractSingleObserver<T>

io.github.resilience4j.rxjava3.ratelimiter.operator.SingleRateLimiter.RateLimiterSingleObserver

All Implemented Interfaces:

io.reactivex.rxjava3.core.SingleObserver<T>, io.reactivex.rxjava3.disposables.Disposable

Enclosing class:

SingleRateLimiter<T>

class SingleRateLimiter.RateLimiterSingleObserver
extends AbstractSingleObserver<T>

Constructor Summary

Constructors

Constructor	Description
RateLimiterSingleObserver(io.reactivex.rxjava3.core.SingleObserver<? super T> downstreamObserver)

Method Summary

Modifier and Type	Method	Description
protected void	hookOnCancel()
protected void	hookOnError(Throwable e)
protected void	hookOnSuccess(T value)

Methods inherited from class AbstractSingleObserver

hookOnSubscribe, onError, onSuccess

Methods inherited from class AbstractDisposable

dispose, isDisposed, onSubscribe, toString

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface io.reactivex.rxjava3.core.SingleObserver

onSubscribe

Constructor Details

RateLimiterSingleObserver

RateLimiterSingleObserver(io.reactivex.rxjava3.core.SingleObserver<? super T> downstreamObserver)

Method Details

hookOnError

protected void hookOnError(Throwable e)

Specified by:

hookOnError in class AbstractSingleObserver<T>

hookOnSuccess

protected void hookOnSuccess(T value)

Specified by:

hookOnSuccess in class AbstractSingleObserver<T>

hookOnCancel

protected void hookOnCancel()

Specified by:

hookOnCancel in class AbstractDisposable