Class CompletableCircuitBreaker.CircuitBreakerCompletableObserver
java.lang.Object
io.github.resilience4j.rxjava3.AbstractDisposable
io.github.resilience4j.rxjava3.AbstractCompletableObserver
io.github.resilience4j.rxjava3.circuitbreaker.operator.CompletableCircuitBreaker.CircuitBreakerCompletableObserver
- All Implemented Interfaces:
io.reactivex.rxjava3.core.CompletableObserver, io.reactivex.rxjava3.disposables.Disposable
- Enclosing class:
CompletableCircuitBreaker
class CompletableCircuitBreaker.CircuitBreakerCompletableObserver
extends AbstractCompletableObserver
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionCircuitBreakerCompletableObserver(io.reactivex.rxjava3.core.CompletableObserver downstreamObserver) -
Method Summary
Modifier and TypeMethodDescriptionprotected voidprotected voidprotected voidMethods inherited from class AbstractCompletableObserver
hookOnSubscribe, onComplete, onErrorMethods inherited from class AbstractDisposable
dispose, isDisposed, onSubscribe, toStringMethods inherited from class Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface io.reactivex.rxjava3.core.CompletableObserver
onSubscribe
-
Field Details
-
start
private final long start
-
-
Constructor Details
-
CircuitBreakerCompletableObserver
CircuitBreakerCompletableObserver(io.reactivex.rxjava3.core.CompletableObserver downstreamObserver)
-
-
Method Details
-
hookOnComplete
protected void hookOnComplete()- Specified by:
hookOnCompletein classAbstractCompletableObserver
-
hookOnError
- Specified by:
hookOnErrorin classAbstractCompletableObserver
-
hookOnCancel
protected void hookOnCancel()- Specified by:
hookOnCancelin classAbstractDisposable
-