Class FlowableRateLimiter.RateLimiterSubscriber

java.lang.Object

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

io.github.resilience4j.rxjava3.ratelimiter.operator.FlowableRateLimiter.RateLimiterSubscriber

All Implemented Interfaces:

io.reactivex.rxjava3.disposables.Disposable, org.reactivestreams.Subscriber<T>, org.reactivestreams.Subscription

Enclosing class:

FlowableRateLimiter<T>

class FlowableRateLimiter.RateLimiterSubscriber
extends AbstractSubscriber<T>

Field Summary

Fields inherited from class AbstractSubscriber

downstreamSubscriber, eventWasEmitted

Constructor Summary

Constructors

Constructor	Description
RateLimiterSubscriber(org.reactivestreams.Subscriber<? super T> downstreamSubscriber)

Method Summary

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

Methods inherited from class AbstractSubscriber

cancel, dispose, isDisposed, onComplete, onError, onNext, onSubscribe, request, toString

Methods inherited from class Object

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

Constructor Details

RateLimiterSubscriber

RateLimiterSubscriber(org.reactivestreams.Subscriber<? super T> downstreamSubscriber)

Method Details

hookOnError

protected void hookOnError(Throwable e)

Specified by:

hookOnError in class AbstractSubscriber<T>

hookOnNext

protected void hookOnNext(T value)

Overrides:

hookOnNext in class AbstractSubscriber<T>

hookOnComplete

public void hookOnComplete()

Specified by:

hookOnComplete in class AbstractSubscriber<T>

hookOnCancel

public void hookOnCancel()

Specified by:

hookOnCancel in class AbstractSubscriber<T>