Class CompletableCircuitBreaker

java.lang.Object
io.reactivex.rxjava3.core.Completable
io.github.resilience4j.rxjava3.circuitbreaker.operator.CompletableCircuitBreaker
All Implemented Interfaces:
io.reactivex.rxjava3.core.CompletableSource
class CompletableCircuitBreaker extends io.reactivex.rxjava3.core.Completable

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    (package private) class 
    CompletableCircuitBreaker.CircuitBreakerCompletableObserver
     

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private final io.github.resilience4j.circuitbreaker.CircuitBreaker
    circuitBreaker
     
    private final io.reactivex.rxjava3.core.Completable
    upstream
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    CompletableCircuitBreaker(io.reactivex.rxjava3.core.Completable upstream, io.github.resilience4j.circuitbreaker.CircuitBreaker circuitBreaker)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    subscribeActual(io.reactivex.rxjava3.core.CompletableObserver downstream)
     

    Methods inherited from class io.reactivex.rxjava3.core.Completable

    amb, ambArray, ambWith, andThen, andThen, andThen, andThen, andThen, blockingAwait, blockingAwait, blockingSubscribe, blockingSubscribe, blockingSubscribe, blockingSubscribe, cache, complete, compose, concat, concat, concat, concatArray, concatArrayDelayError, concatDelayError, concatDelayError, concatDelayError, concatWith, create, defer, delay, delay, delay, delaySubscription, delaySubscription, doAfterTerminate, doFinally, doOnComplete, doOnDispose, doOnError, doOnEvent, doOnLifecycle, doOnSubscribe, doOnTerminate, error, error, fromAction, fromCallable, fromCompletionStage, fromFuture, fromMaybe, fromObservable, fromPublisher, fromRunnable, fromSingle, fromSupplier, hide, lift, materialize, merge, merge, merge, mergeArray, mergeArrayDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeWith, never, observeOn, onErrorComplete, onErrorComplete, onErrorResumeNext, onErrorResumeWith, onErrorReturn, onErrorReturnItem, onTerminateDetach, repeat, repeat, repeatUntil, repeatWhen, retry, retry, retry, retry, retry, retryUntil, retryWhen, safeSubscribe, sequenceEqual, startWith, startWith, startWith, startWith, startWith, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeWith, switchOnNext, switchOnNextDelayError, takeUntil, test, test, timeout, timeout, timeout, timeout, timer, timer, to, toCompletionStage, toFlowable, toFuture, toMaybe, toObservable, toSingle, toSingleDefault, unsafeCreate, unsubscribeOn, using, using, wrap

    Methods inherited from class Object

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

  • Field Details

    • upstream

      private final io.reactivex.rxjava3.core.Completable upstream

    • circuitBreaker

      private final io.github.resilience4j.circuitbreaker.CircuitBreaker circuitBreaker

  • Constructor Details

    • CompletableCircuitBreaker

      CompletableCircuitBreaker(io.reactivex.rxjava3.core.Completable upstream, io.github.resilience4j.circuitbreaker.CircuitBreaker circuitBreaker)

  • Method Details

    • subscribeActual

      protected void subscribeActual(io.reactivex.rxjava3.core.CompletableObserver downstream)
      Specified by:
      subscribeActual in class io.reactivex.rxjava3.core.Completable