Class FlowableCircuitBreaker.CircuitBreakerSubscriber

java.lang.Object

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

io.github.resilience4j.rxjava3.circuitbreaker.operator.FlowableCircuitBreaker.CircuitBreakerSubscriber

All Implemented Interfaces:

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

Enclosing class:

FlowableCircuitBreaker<T>

class FlowableCircuitBreaker.CircuitBreakerSubscriber
extends AbstractSubscriber<T>

Field Summary

Fields

Modifier and Type	Field	Description
private final long	start

Fields inherited from class AbstractSubscriber

downstreamSubscriber, eventWasEmitted

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class AbstractSubscriber

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

Methods inherited from class Object

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

Field Details

start

private final long start

Constructor Details

CircuitBreakerSubscriber

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

Method Details

hookOnError

public void hookOnError(Throwable t)

Specified by:

hookOnError 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>