Class ObserverRateLimiter.RateLimiterObserver

java.lang.Object

io.github.resilience4j.rxjava3.AbstractDisposable

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

io.github.resilience4j.rxjava3.ratelimiter.operator.ObserverRateLimiter.RateLimiterObserver

All Implemented Interfaces:

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

Enclosing class:

ObserverRateLimiter<T>

class ObserverRateLimiter.RateLimiterObserver
extends AbstractObserver<T>

Field Summary

Fields inherited from class AbstractObserver

eventWasEmitted

Constructor Summary

Constructors

Constructor	Description
RateLimiterObserver(io.reactivex.rxjava3.core.Observer<? super T> downstreamObserver)

Method Summary

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

Methods inherited from class AbstractObserver

hookOnSubscribe, onComplete, onError, onNext

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.Observer

onSubscribe

Constructor Details

RateLimiterObserver

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

Method Details

hookOnError

protected void hookOnError(Throwable e)

Specified by:

hookOnError in class AbstractObserver<T>

hookOnNext

protected void hookOnNext(T value)

Overrides:

hookOnNext in class AbstractObserver<T>

hookOnComplete

protected void hookOnComplete()

Specified by:

hookOnComplete in class AbstractObserver<T>

hookOnCancel

protected void hookOnCancel()

Specified by:

hookOnCancel in class AbstractDisposable