Class CompletableRateLimiter.RateLimiterCompletableObserver

java.lang.Object

io.github.resilience4j.rxjava3.AbstractDisposable

io.github.resilience4j.rxjava3.AbstractCompletableObserver

io.github.resilience4j.rxjava3.ratelimiter.operator.CompletableRateLimiter.RateLimiterCompletableObserver

All Implemented Interfaces:

io.reactivex.rxjava3.core.CompletableObserver, io.reactivex.rxjava3.disposables.Disposable

Enclosing class:

CompletableRateLimiter

class CompletableRateLimiter.RateLimiterCompletableObserver
extends AbstractCompletableObserver

Constructor Summary

Constructors

Constructor	Description
RateLimiterCompletableObserver(io.reactivex.rxjava3.core.CompletableObserver downstreamObserver)

Method Summary

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

Methods inherited from class AbstractCompletableObserver

hookOnSubscribe, onComplete, onError

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

onSubscribe

Constructor Details

RateLimiterCompletableObserver

RateLimiterCompletableObserver(io.reactivex.rxjava3.core.CompletableObserver downstreamObserver)

Method Details

hookOnComplete

protected void hookOnComplete()

Specified by:

hookOnComplete in class AbstractCompletableObserver

hookOnError

protected void hookOnError(Throwable e)

Specified by:

hookOnError in class AbstractCompletableObserver

hookOnCancel

protected void hookOnCancel()

Specified by:

hookOnCancel in class AbstractDisposable