Class MaybeCircuitBreaker<T>

java.lang.Object
io.reactivex.rxjava3.core.Maybe<T>
io.github.resilience4j.rxjava3.circuitbreaker.operator.MaybeCircuitBreaker<T>
All Implemented Interfaces:
io.reactivex.rxjava3.core.MaybeSource<T>
class MaybeCircuitBreaker<T> extends io.reactivex.rxjava3.core.Maybe<T>

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    (package private) class 
    MaybeCircuitBreaker.CircuitBreakerMaybeObserver
     

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private final io.github.resilience4j.circuitbreaker.CircuitBreaker
    circuitBreaker
     
    private final io.reactivex.rxjava3.core.Maybe<T>
    upstream
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    MaybeCircuitBreaker(io.reactivex.rxjava3.core.Maybe<T> upstream, io.github.resilience4j.circuitbreaker.CircuitBreaker circuitBreaker)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    subscribeActual(io.reactivex.rxjava3.core.MaybeObserver<? super T> downstream)
     

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

    amb, ambArray, ambWith, blockingGet, blockingGet, blockingSubscribe, blockingSubscribe, blockingSubscribe, blockingSubscribe, blockingSubscribe, cache, cast, compose, concat, concat, concat, concat, concat, concat, concatArray, concatArrayDelayError, concatArrayEager, concatArrayEagerDelayError, concatDelayError, concatDelayError, concatDelayError, concatEager, concatEager, concatEager, concatEager, concatEagerDelayError, concatEagerDelayError, concatEagerDelayError, concatEagerDelayError, concatMap, concatMapCompletable, concatMapSingle, concatWith, contains, count, create, defaultIfEmpty, defer, delay, delay, delay, delay, delay, delaySubscription, delaySubscription, delaySubscription, dematerialize, doAfterSuccess, doAfterTerminate, doFinally, doOnComplete, doOnDispose, doOnError, doOnEvent, doOnLifecycle, doOnSubscribe, doOnSuccess, doOnTerminate, empty, error, error, filter, flatMap, flatMap, flatMap, flatMapCompletable, flatMapObservable, flatMapPublisher, flatMapSingle, flattenAsFlowable, flattenAsObservable, flattenStreamAsFlowable, flattenStreamAsObservable, fromAction, fromCallable, fromCompletable, fromCompletionStage, fromFuture, fromFuture, fromObservable, fromOptional, fromPublisher, fromRunnable, fromSingle, fromSupplier, hide, ignoreElement, isEmpty, just, lift, map, mapOptional, materialize, merge, merge, merge, merge, merge, merge, merge, mergeArray, mergeArrayDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeWith, never, observeOn, ofType, onErrorComplete, onErrorComplete, onErrorResumeNext, onErrorResumeWith, onErrorReturn, onErrorReturnItem, onTerminateDetach, repeat, repeat, repeatUntil, repeatWhen, retry, retry, retry, retry, retry, retryUntil, retryWhen, safeSubscribe, sequenceEqual, sequenceEqual, startWith, startWith, startWith, startWith, startWith, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeWith, switchIfEmpty, switchIfEmpty, switchOnNext, switchOnNextDelayError, takeUntil, takeUntil, test, test, timeInterval, timeInterval, timeInterval, timeInterval, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timer, timer, timestamp, timestamp, timestamp, timestamp, to, toCompletionStage, toCompletionStage, toFlowable, toFuture, toObservable, toSingle, unsafeCreate, unsubscribeOn, using, using, wrap, zip, zip, zip, zip, zip, zip, zip, zip, zip, zipArray, zipWith

    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.Maybe<T> upstream

    • circuitBreaker

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

  • Constructor Details

    • MaybeCircuitBreaker

      MaybeCircuitBreaker(io.reactivex.rxjava3.core.Maybe<T> upstream, io.github.resilience4j.circuitbreaker.CircuitBreaker circuitBreaker)

  • Method Details

    • subscribeActual

      protected void subscribeActual(io.reactivex.rxjava3.core.MaybeObserver<? super T> downstream)
      Specified by:
      subscribeActual in class io.reactivex.rxjava3.core.Maybe<T>