Class CompletableBulkhead

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

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    (package private) class 
    CompletableBulkhead.BulkheadCompletableObserver
     

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private final io.github.resilience4j.bulkhead.Bulkhead
    bulkhead
     
    private final io.reactivex.rxjava3.core.Completable
    upstream
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    CompletableBulkhead(io.reactivex.rxjava3.core.Completable upstream, io.github.resilience4j.bulkhead.Bulkhead bulkhead)
     

  • 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

    • bulkhead

      private final io.github.resilience4j.bulkhead.Bulkhead bulkhead

  • Constructor Details

    • CompletableBulkhead

      CompletableBulkhead(io.reactivex.rxjava3.core.Completable upstream, io.github.resilience4j.bulkhead.Bulkhead bulkhead)

  • Method Details

    • subscribeActual

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