Class MaybeRateLimiter.RateLimiterMaybeObserver

java.lang.Object

io.github.resilience4j.rxjava3.AbstractDisposable

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

io.github.resilience4j.rxjava3.ratelimiter.operator.MaybeRateLimiter.RateLimiterMaybeObserver

All Implemented Interfaces:

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

Enclosing class:

MaybeRateLimiter<T>

class MaybeRateLimiter.RateLimiterMaybeObserver
extends AbstractMaybeObserver<T>

Constructor Summary

Constructors

Constructor	Description
RateLimiterMaybeObserver(io.reactivex.rxjava3.core.MaybeObserver<? super T> downstreamObserver)

Method Summary

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

Methods inherited from class AbstractMaybeObserver

hookOnSubscribe, onComplete, 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.MaybeObserver

onSubscribe

Constructor Details

RateLimiterMaybeObserver

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

Method Details

hookOnComplete

protected void hookOnComplete()

Specified by:

hookOnComplete in class AbstractMaybeObserver<T>

hookOnError

protected void hookOnError(Throwable e)

Specified by:

hookOnError in class AbstractMaybeObserver<T>

hookOnSuccess

protected void hookOnSuccess(T value)

Specified by:

hookOnSuccess in class AbstractMaybeObserver<T>

hookOnCancel

protected void hookOnCancel()

Specified by:

hookOnCancel in class AbstractDisposable