Class FlowableBulkhead.BulkheadSubscriber

java.lang.Object

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

io.github.resilience4j.rxjava3.bulkhead.operator.FlowableBulkhead.BulkheadSubscriber

All Implemented Interfaces:

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

Enclosing class:

FlowableBulkhead<T>

class FlowableBulkhead.BulkheadSubscriber
extends AbstractSubscriber<T>

Field Summary

Fields inherited from class AbstractSubscriber

downstreamSubscriber, eventWasEmitted

Constructor Summary

Constructors

Constructor	Description
BulkheadSubscriber(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

Constructor Details

BulkheadSubscriber

BulkheadSubscriber(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>