Class CompletableRateLimiter

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

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    (package private) class 
    CompletableRateLimiter.RateLimiterCompletableObserver
     

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private final io.github.resilience4j.ratelimiter.RateLimiter
    rateLimiter
     
    private final io.reactivex.rxjava3.core.Completable
    upstream
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    CompletableRateLimiter(io.reactivex.rxjava3.core.Completable upstream, io.github.resilience4j.ratelimiter.RateLimiter rateLimiter)
     

  • 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

    • rateLimiter

      private final io.github.resilience4j.ratelimiter.RateLimiter rateLimiter

  • Constructor Details

    • CompletableRateLimiter

      CompletableRateLimiter(io.reactivex.rxjava3.core.Completable upstream, io.github.resilience4j.ratelimiter.RateLimiter rateLimiter)

  • Method Details

    • subscribeActual

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