Class MaybeRateLimiter<T>

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

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    (package private) class 
    MaybeRateLimiter.RateLimiterMaybeObserver
     

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private final io.github.resilience4j.ratelimiter.RateLimiter
    rateLimiter
     
    private final io.reactivex.rxjava3.core.Maybe<T>
    upstream
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    MaybeRateLimiter(io.reactivex.rxjava3.core.Maybe<T> upstream, io.github.resilience4j.ratelimiter.RateLimiter rateLimiter)
     

  • 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

    • rateLimiter

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

  • Constructor Details

    • MaybeRateLimiter

      MaybeRateLimiter(io.reactivex.rxjava3.core.Maybe<T> upstream, io.github.resilience4j.ratelimiter.RateLimiter rateLimiter)

  • 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>