Index
All Classes and Interfaces|All Packages
A
- AbstractCompletableObserver - Class in io.github.resilience4j.rxjava3
- AbstractCompletableObserver(CompletableObserver) - Constructor for class io.github.resilience4j.rxjava3.AbstractCompletableObserver
- AbstractDisposable - Class in io.github.resilience4j.rxjava3
- AbstractDisposable() - Constructor for class io.github.resilience4j.rxjava3.AbstractDisposable
- AbstractMaybeObserver<T> - Class in io.github.resilience4j.rxjava3
- AbstractMaybeObserver(MaybeObserver) - Constructor for class io.github.resilience4j.rxjava3.AbstractMaybeObserver
- AbstractObserver<T> - Class in io.github.resilience4j.rxjava3
- AbstractObserver(Observer) - Constructor for class io.github.resilience4j.rxjava3.AbstractObserver
- AbstractSingleObserver<T> - Class in io.github.resilience4j.rxjava3
- AbstractSingleObserver(SingleObserver) - Constructor for class io.github.resilience4j.rxjava3.AbstractSingleObserver
- AbstractSubscriber<T> - Class in io.github.resilience4j.rxjava3
- AbstractSubscriber(Subscriber) - Constructor for class io.github.resilience4j.rxjava3.AbstractSubscriber
- apply(Completable) - Method in class io.github.resilience4j.rxjava3.bulkhead.operator.BulkheadOperator
- apply(Completable) - Method in class io.github.resilience4j.rxjava3.circuitbreaker.operator.CircuitBreakerOperator
- apply(Completable) - Method in class io.github.resilience4j.rxjava3.ratelimiter.operator.RateLimiterOperator
- apply(Completable) - Method in class io.github.resilience4j.rxjava3.retry.transformer.RetryTransformer
- apply(Completable) - Method in class io.github.resilience4j.rxjava3.timelimiter.transformer.TimeLimiterTransformer
- apply(Flowable) - Method in class io.github.resilience4j.rxjava3.bulkhead.operator.BulkheadOperator
- apply(Flowable) - Method in class io.github.resilience4j.rxjava3.circuitbreaker.operator.CircuitBreakerOperator
- apply(Flowable) - Method in class io.github.resilience4j.rxjava3.ratelimiter.operator.RateLimiterOperator
- apply(Flowable) - Method in class io.github.resilience4j.rxjava3.retry.transformer.RetryTransformer
- apply(Flowable) - Method in class io.github.resilience4j.rxjava3.timelimiter.transformer.TimeLimiterTransformer
- apply(Maybe) - Method in class io.github.resilience4j.rxjava3.bulkhead.operator.BulkheadOperator
- apply(Maybe) - Method in class io.github.resilience4j.rxjava3.circuitbreaker.operator.CircuitBreakerOperator
- apply(Maybe) - Method in class io.github.resilience4j.rxjava3.ratelimiter.operator.RateLimiterOperator
- apply(Maybe) - Method in class io.github.resilience4j.rxjava3.retry.transformer.RetryTransformer
- apply(Maybe) - Method in class io.github.resilience4j.rxjava3.timelimiter.transformer.TimeLimiterTransformer
- apply(Observable) - Method in class io.github.resilience4j.rxjava3.bulkhead.operator.BulkheadOperator
- apply(Observable) - Method in class io.github.resilience4j.rxjava3.circuitbreaker.operator.CircuitBreakerOperator
- apply(Observable) - Method in class io.github.resilience4j.rxjava3.ratelimiter.operator.RateLimiterOperator
- apply(Observable) - Method in class io.github.resilience4j.rxjava3.retry.transformer.RetryTransformer
- apply(Observable) - Method in class io.github.resilience4j.rxjava3.timelimiter.transformer.TimeLimiterTransformer
- apply(Single) - Method in class io.github.resilience4j.rxjava3.bulkhead.operator.BulkheadOperator
- apply(Single) - Method in class io.github.resilience4j.rxjava3.circuitbreaker.operator.CircuitBreakerOperator
- apply(Single) - Method in class io.github.resilience4j.rxjava3.ratelimiter.operator.RateLimiterOperator
- apply(Single) - Method in class io.github.resilience4j.rxjava3.retry.transformer.RetryTransformer
- apply(Single) - Method in class io.github.resilience4j.rxjava3.timelimiter.transformer.TimeLimiterTransformer
B
- bulkhead - Variable in class io.github.resilience4j.rxjava3.bulkhead.operator.BulkheadOperator
- bulkhead - Variable in class io.github.resilience4j.rxjava3.bulkhead.operator.CompletableBulkhead
- bulkhead - Variable in class io.github.resilience4j.rxjava3.bulkhead.operator.FlowableBulkhead
- bulkhead - Variable in class io.github.resilience4j.rxjava3.bulkhead.operator.MaybeBulkhead
- bulkhead - Variable in class io.github.resilience4j.rxjava3.bulkhead.operator.ObserverBulkhead
- bulkhead - Variable in class io.github.resilience4j.rxjava3.bulkhead.operator.SingleBulkhead
- BulkheadCompletableObserver(CompletableObserver) - Constructor for class io.github.resilience4j.rxjava3.bulkhead.operator.CompletableBulkhead.BulkheadCompletableObserver
- BulkheadMaybeObserver(MaybeObserver) - Constructor for class io.github.resilience4j.rxjava3.bulkhead.operator.MaybeBulkhead.BulkheadMaybeObserver
- BulkheadObserver(Observer) - Constructor for class io.github.resilience4j.rxjava3.bulkhead.operator.ObserverBulkhead.BulkheadObserver
- BulkheadOperator<T> - Class in io.github.resilience4j.rxjava3.bulkhead.operator
-
A Bulkhead operator which checks if a subscriber/observer can acquire a permission to subscribe to an upstream Publisher.
- BulkheadOperator(Bulkhead) - Constructor for class io.github.resilience4j.rxjava3.bulkhead.operator.BulkheadOperator
- BulkheadSingleObserver(SingleObserver) - Constructor for class io.github.resilience4j.rxjava3.bulkhead.operator.SingleBulkhead.BulkheadSingleObserver
- BulkheadSubscriber(Subscriber) - Constructor for class io.github.resilience4j.rxjava3.bulkhead.operator.FlowableBulkhead.BulkheadSubscriber
C
- cancel() - Method in class io.github.resilience4j.rxjava3.AbstractSubscriber
- circuitBreaker - Variable in class io.github.resilience4j.rxjava3.circuitbreaker.operator.CircuitBreakerOperator
- circuitBreaker - Variable in class io.github.resilience4j.rxjava3.circuitbreaker.operator.CompletableCircuitBreaker
- circuitBreaker - Variable in class io.github.resilience4j.rxjava3.circuitbreaker.operator.FlowableCircuitBreaker
- circuitBreaker - Variable in class io.github.resilience4j.rxjava3.circuitbreaker.operator.MaybeCircuitBreaker
- circuitBreaker - Variable in class io.github.resilience4j.rxjava3.circuitbreaker.operator.ObserverCircuitBreaker
- circuitBreaker - Variable in class io.github.resilience4j.rxjava3.circuitbreaker.operator.SingleCircuitBreaker
- CircuitBreakerCompletableObserver(CompletableObserver) - Constructor for class io.github.resilience4j.rxjava3.circuitbreaker.operator.CompletableCircuitBreaker.CircuitBreakerCompletableObserver
- CircuitBreakerMaybeObserver(MaybeObserver) - Constructor for class io.github.resilience4j.rxjava3.circuitbreaker.operator.MaybeCircuitBreaker.CircuitBreakerMaybeObserver
- CircuitBreakerObserver(Observer) - Constructor for class io.github.resilience4j.rxjava3.circuitbreaker.operator.ObserverCircuitBreaker.CircuitBreakerObserver
- CircuitBreakerOperator<T> - Class in io.github.resilience4j.rxjava3.circuitbreaker.operator
-
A CircuitBreaker operator which checks if a downstream subscriber/observer can acquire a permission to subscribe to an upstream Publisher.
- CircuitBreakerOperator(CircuitBreaker) - Constructor for class io.github.resilience4j.rxjava3.circuitbreaker.operator.CircuitBreakerOperator
- CircuitBreakerSingleObserver(SingleObserver) - Constructor for class io.github.resilience4j.rxjava3.circuitbreaker.operator.SingleCircuitBreaker.CircuitBreakerSingleObserver
- CircuitBreakerSubscriber(Subscriber) - Constructor for class io.github.resilience4j.rxjava3.circuitbreaker.operator.FlowableCircuitBreaker.CircuitBreakerSubscriber
- CompletableBulkhead - Class in io.github.resilience4j.rxjava3.bulkhead.operator
- CompletableBulkhead(Completable, Bulkhead) - Constructor for class io.github.resilience4j.rxjava3.bulkhead.operator.CompletableBulkhead
- CompletableBulkhead.BulkheadCompletableObserver - Class in io.github.resilience4j.rxjava3.bulkhead.operator
- CompletableCircuitBreaker - Class in io.github.resilience4j.rxjava3.circuitbreaker.operator
- CompletableCircuitBreaker(Completable, CircuitBreaker) - Constructor for class io.github.resilience4j.rxjava3.circuitbreaker.operator.CompletableCircuitBreaker
- CompletableCircuitBreaker.CircuitBreakerCompletableObserver - Class in io.github.resilience4j.rxjava3.circuitbreaker.operator
- CompletableRateLimiter - Class in io.github.resilience4j.rxjava3.ratelimiter.operator
- CompletableRateLimiter(Completable, RateLimiter) - Constructor for class io.github.resilience4j.rxjava3.ratelimiter.operator.CompletableRateLimiter
- CompletableRateLimiter.RateLimiterCompletableObserver - Class in io.github.resilience4j.rxjava3.ratelimiter.operator
- Context(Retry.AsyncContext) - Constructor for class io.github.resilience4j.rxjava3.retry.transformer.RetryTransformer.Context
D
- dispose() - Method in class io.github.resilience4j.rxjava3.AbstractDisposable
- dispose() - Method in class io.github.resilience4j.rxjava3.AbstractSubscriber
- downstreamObserver - Variable in class io.github.resilience4j.rxjava3.AbstractCompletableObserver
- downstreamObserver - Variable in class io.github.resilience4j.rxjava3.AbstractMaybeObserver
- downstreamObserver - Variable in class io.github.resilience4j.rxjava3.AbstractObserver
- downstreamObserver - Variable in class io.github.resilience4j.rxjava3.AbstractSingleObserver
- downstreamSubscriber - Variable in class io.github.resilience4j.rxjava3.AbstractSubscriber
E
- eventWasEmitted - Variable in class io.github.resilience4j.rxjava3.AbstractObserver
- eventWasEmitted - Variable in class io.github.resilience4j.rxjava3.AbstractSubscriber
F
- FlowableBulkhead<T> - Class in io.github.resilience4j.rxjava3.bulkhead.operator
- FlowableBulkhead(Publisher, Bulkhead) - Constructor for class io.github.resilience4j.rxjava3.bulkhead.operator.FlowableBulkhead
- FlowableBulkhead.BulkheadSubscriber - Class in io.github.resilience4j.rxjava3.bulkhead.operator
- FlowableCircuitBreaker<T> - Class in io.github.resilience4j.rxjava3.circuitbreaker.operator
- FlowableCircuitBreaker(Publisher, CircuitBreaker) - Constructor for class io.github.resilience4j.rxjava3.circuitbreaker.operator.FlowableCircuitBreaker
- FlowableCircuitBreaker.CircuitBreakerSubscriber - Class in io.github.resilience4j.rxjava3.circuitbreaker.operator
- FlowableRateLimiter<T> - Class in io.github.resilience4j.rxjava3.ratelimiter.operator
- FlowableRateLimiter(Publisher, RateLimiter) - Constructor for class io.github.resilience4j.rxjava3.ratelimiter.operator.FlowableRateLimiter
- FlowableRateLimiter.RateLimiterSubscriber - Class in io.github.resilience4j.rxjava3.ratelimiter.operator
G
- getTimeoutInMillis() - Method in class io.github.resilience4j.rxjava3.timelimiter.transformer.TimeLimiterTransformer
H
- handleFlowableErrors(Throwable) - Method in class io.github.resilience4j.rxjava3.retry.transformer.RetryTransformer.Context
- handleObservableErrors(Throwable) - Method in class io.github.resilience4j.rxjava3.retry.transformer.RetryTransformer.Context
- handleResult(T) - Method in class io.github.resilience4j.rxjava3.retry.transformer.RetryTransformer.Context
- hookOnCancel() - Method in class io.github.resilience4j.rxjava3.AbstractDisposable
- hookOnCancel() - Method in class io.github.resilience4j.rxjava3.AbstractSubscriber
- hookOnCancel() - Method in class io.github.resilience4j.rxjava3.bulkhead.operator.CompletableBulkhead.BulkheadCompletableObserver
- hookOnCancel() - Method in class io.github.resilience4j.rxjava3.bulkhead.operator.FlowableBulkhead.BulkheadSubscriber
- hookOnCancel() - Method in class io.github.resilience4j.rxjava3.bulkhead.operator.MaybeBulkhead.BulkheadMaybeObserver
- hookOnCancel() - Method in class io.github.resilience4j.rxjava3.bulkhead.operator.ObserverBulkhead.BulkheadObserver
- hookOnCancel() - Method in class io.github.resilience4j.rxjava3.bulkhead.operator.SingleBulkhead.BulkheadSingleObserver
- hookOnCancel() - Method in class io.github.resilience4j.rxjava3.circuitbreaker.operator.CompletableCircuitBreaker.CircuitBreakerCompletableObserver
- hookOnCancel() - Method in class io.github.resilience4j.rxjava3.circuitbreaker.operator.FlowableCircuitBreaker.CircuitBreakerSubscriber
- hookOnCancel() - Method in class io.github.resilience4j.rxjava3.circuitbreaker.operator.MaybeCircuitBreaker.CircuitBreakerMaybeObserver
- hookOnCancel() - Method in class io.github.resilience4j.rxjava3.circuitbreaker.operator.ObserverCircuitBreaker.CircuitBreakerObserver
- hookOnCancel() - Method in class io.github.resilience4j.rxjava3.circuitbreaker.operator.SingleCircuitBreaker.CircuitBreakerSingleObserver
- hookOnCancel() - Method in class io.github.resilience4j.rxjava3.ratelimiter.operator.CompletableRateLimiter.RateLimiterCompletableObserver
- hookOnCancel() - Method in class io.github.resilience4j.rxjava3.ratelimiter.operator.FlowableRateLimiter.RateLimiterSubscriber
- hookOnCancel() - Method in class io.github.resilience4j.rxjava3.ratelimiter.operator.MaybeRateLimiter.RateLimiterMaybeObserver
- hookOnCancel() - Method in class io.github.resilience4j.rxjava3.ratelimiter.operator.ObserverRateLimiter.RateLimiterObserver
- hookOnCancel() - Method in class io.github.resilience4j.rxjava3.ratelimiter.operator.SingleRateLimiter.RateLimiterSingleObserver
- hookOnComplete() - Method in class io.github.resilience4j.rxjava3.AbstractCompletableObserver
- hookOnComplete() - Method in class io.github.resilience4j.rxjava3.AbstractMaybeObserver
- hookOnComplete() - Method in class io.github.resilience4j.rxjava3.AbstractObserver
- hookOnComplete() - Method in class io.github.resilience4j.rxjava3.AbstractSubscriber
- hookOnComplete() - Method in class io.github.resilience4j.rxjava3.bulkhead.operator.CompletableBulkhead.BulkheadCompletableObserver
- hookOnComplete() - Method in class io.github.resilience4j.rxjava3.bulkhead.operator.FlowableBulkhead.BulkheadSubscriber
- hookOnComplete() - Method in class io.github.resilience4j.rxjava3.bulkhead.operator.MaybeBulkhead.BulkheadMaybeObserver
- hookOnComplete() - Method in class io.github.resilience4j.rxjava3.bulkhead.operator.ObserverBulkhead.BulkheadObserver
- hookOnComplete() - Method in class io.github.resilience4j.rxjava3.circuitbreaker.operator.CompletableCircuitBreaker.CircuitBreakerCompletableObserver
- hookOnComplete() - Method in class io.github.resilience4j.rxjava3.circuitbreaker.operator.FlowableCircuitBreaker.CircuitBreakerSubscriber
- hookOnComplete() - Method in class io.github.resilience4j.rxjava3.circuitbreaker.operator.MaybeCircuitBreaker.CircuitBreakerMaybeObserver
- hookOnComplete() - Method in class io.github.resilience4j.rxjava3.circuitbreaker.operator.ObserverCircuitBreaker.CircuitBreakerObserver
- hookOnComplete() - Method in class io.github.resilience4j.rxjava3.ratelimiter.operator.CompletableRateLimiter.RateLimiterCompletableObserver
- hookOnComplete() - Method in class io.github.resilience4j.rxjava3.ratelimiter.operator.FlowableRateLimiter.RateLimiterSubscriber
- hookOnComplete() - Method in class io.github.resilience4j.rxjava3.ratelimiter.operator.MaybeRateLimiter.RateLimiterMaybeObserver
- hookOnComplete() - Method in class io.github.resilience4j.rxjava3.ratelimiter.operator.ObserverRateLimiter.RateLimiterObserver
- hookOnError(Throwable) - Method in class io.github.resilience4j.rxjava3.AbstractCompletableObserver
- hookOnError(Throwable) - Method in class io.github.resilience4j.rxjava3.AbstractMaybeObserver
- hookOnError(Throwable) - Method in class io.github.resilience4j.rxjava3.AbstractObserver
- hookOnError(Throwable) - Method in class io.github.resilience4j.rxjava3.AbstractSingleObserver
- hookOnError(Throwable) - Method in class io.github.resilience4j.rxjava3.AbstractSubscriber
- hookOnError(Throwable) - Method in class io.github.resilience4j.rxjava3.bulkhead.operator.CompletableBulkhead.BulkheadCompletableObserver
- hookOnError(Throwable) - Method in class io.github.resilience4j.rxjava3.bulkhead.operator.FlowableBulkhead.BulkheadSubscriber
- hookOnError(Throwable) - Method in class io.github.resilience4j.rxjava3.bulkhead.operator.MaybeBulkhead.BulkheadMaybeObserver
- hookOnError(Throwable) - Method in class io.github.resilience4j.rxjava3.bulkhead.operator.ObserverBulkhead.BulkheadObserver
- hookOnError(Throwable) - Method in class io.github.resilience4j.rxjava3.bulkhead.operator.SingleBulkhead.BulkheadSingleObserver
- hookOnError(Throwable) - Method in class io.github.resilience4j.rxjava3.circuitbreaker.operator.CompletableCircuitBreaker.CircuitBreakerCompletableObserver
- hookOnError(Throwable) - Method in class io.github.resilience4j.rxjava3.circuitbreaker.operator.FlowableCircuitBreaker.CircuitBreakerSubscriber
- hookOnError(Throwable) - Method in class io.github.resilience4j.rxjava3.circuitbreaker.operator.MaybeCircuitBreaker.CircuitBreakerMaybeObserver
- hookOnError(Throwable) - Method in class io.github.resilience4j.rxjava3.circuitbreaker.operator.ObserverCircuitBreaker.CircuitBreakerObserver
- hookOnError(Throwable) - Method in class io.github.resilience4j.rxjava3.circuitbreaker.operator.SingleCircuitBreaker.CircuitBreakerSingleObserver
- hookOnError(Throwable) - Method in class io.github.resilience4j.rxjava3.ratelimiter.operator.CompletableRateLimiter.RateLimiterCompletableObserver
- hookOnError(Throwable) - Method in class io.github.resilience4j.rxjava3.ratelimiter.operator.FlowableRateLimiter.RateLimiterSubscriber
- hookOnError(Throwable) - Method in class io.github.resilience4j.rxjava3.ratelimiter.operator.MaybeRateLimiter.RateLimiterMaybeObserver
- hookOnError(Throwable) - Method in class io.github.resilience4j.rxjava3.ratelimiter.operator.ObserverRateLimiter.RateLimiterObserver
- hookOnError(Throwable) - Method in class io.github.resilience4j.rxjava3.ratelimiter.operator.SingleRateLimiter.RateLimiterSingleObserver
- hookOnNext(T) - Method in class io.github.resilience4j.rxjava3.AbstractObserver
- hookOnNext(T) - Method in class io.github.resilience4j.rxjava3.AbstractSubscriber
- hookOnNext(T) - Method in class io.github.resilience4j.rxjava3.ratelimiter.operator.FlowableRateLimiter.RateLimiterSubscriber
- hookOnNext(T) - Method in class io.github.resilience4j.rxjava3.ratelimiter.operator.ObserverRateLimiter.RateLimiterObserver
- hookOnSubscribe() - Method in class io.github.resilience4j.rxjava3.AbstractCompletableObserver
- hookOnSubscribe() - Method in class io.github.resilience4j.rxjava3.AbstractDisposable
- hookOnSubscribe() - Method in class io.github.resilience4j.rxjava3.AbstractMaybeObserver
- hookOnSubscribe() - Method in class io.github.resilience4j.rxjava3.AbstractObserver
- hookOnSubscribe() - Method in class io.github.resilience4j.rxjava3.AbstractSingleObserver
- hookOnSuccess(T) - Method in class io.github.resilience4j.rxjava3.AbstractMaybeObserver
- hookOnSuccess(T) - Method in class io.github.resilience4j.rxjava3.AbstractSingleObserver
- hookOnSuccess(T) - Method in class io.github.resilience4j.rxjava3.bulkhead.operator.MaybeBulkhead.BulkheadMaybeObserver
- hookOnSuccess(T) - Method in class io.github.resilience4j.rxjava3.bulkhead.operator.SingleBulkhead.BulkheadSingleObserver
- hookOnSuccess(T) - Method in class io.github.resilience4j.rxjava3.circuitbreaker.operator.MaybeCircuitBreaker.CircuitBreakerMaybeObserver
- hookOnSuccess(T) - Method in class io.github.resilience4j.rxjava3.circuitbreaker.operator.SingleCircuitBreaker.CircuitBreakerSingleObserver
- hookOnSuccess(T) - Method in class io.github.resilience4j.rxjava3.ratelimiter.operator.MaybeRateLimiter.RateLimiterMaybeObserver
- hookOnSuccess(T) - Method in class io.github.resilience4j.rxjava3.ratelimiter.operator.SingleRateLimiter.RateLimiterSingleObserver
I
- io.github.resilience4j.rxjava3 - package io.github.resilience4j.rxjava3
- io.github.resilience4j.rxjava3.adapter - package io.github.resilience4j.rxjava3.adapter
- io.github.resilience4j.rxjava3.bulkhead.operator - package io.github.resilience4j.rxjava3.bulkhead.operator
- io.github.resilience4j.rxjava3.circuitbreaker.operator - package io.github.resilience4j.rxjava3.circuitbreaker.operator
- io.github.resilience4j.rxjava3.ratelimiter.operator - package io.github.resilience4j.rxjava3.ratelimiter.operator
- io.github.resilience4j.rxjava3.retry.transformer - package io.github.resilience4j.rxjava3.retry.transformer
- io.github.resilience4j.rxjava3.timelimiter.transformer - package io.github.resilience4j.rxjava3.timelimiter.transformer
- isDisposed() - Method in class io.github.resilience4j.rxjava3.AbstractDisposable
- isDisposed() - Method in class io.github.resilience4j.rxjava3.AbstractSubscriber
M
- MaybeBulkhead<T> - Class in io.github.resilience4j.rxjava3.bulkhead.operator
- MaybeBulkhead(Maybe, Bulkhead) - Constructor for class io.github.resilience4j.rxjava3.bulkhead.operator.MaybeBulkhead
- MaybeBulkhead.BulkheadMaybeObserver - Class in io.github.resilience4j.rxjava3.bulkhead.operator
- MaybeCircuitBreaker<T> - Class in io.github.resilience4j.rxjava3.circuitbreaker.operator
- MaybeCircuitBreaker(Maybe, CircuitBreaker) - Constructor for class io.github.resilience4j.rxjava3.circuitbreaker.operator.MaybeCircuitBreaker
- MaybeCircuitBreaker.CircuitBreakerMaybeObserver - Class in io.github.resilience4j.rxjava3.circuitbreaker.operator
- MaybeRateLimiter<T> - Class in io.github.resilience4j.rxjava3.ratelimiter.operator
- MaybeRateLimiter(Maybe, RateLimiter) - Constructor for class io.github.resilience4j.rxjava3.ratelimiter.operator.MaybeRateLimiter
- MaybeRateLimiter.RateLimiterMaybeObserver - Class in io.github.resilience4j.rxjava3.ratelimiter.operator
O
- ObserverBulkhead<T> - Class in io.github.resilience4j.rxjava3.bulkhead.operator
- ObserverBulkhead(Observable, Bulkhead) - Constructor for class io.github.resilience4j.rxjava3.bulkhead.operator.ObserverBulkhead
- ObserverBulkhead.BulkheadObserver - Class in io.github.resilience4j.rxjava3.bulkhead.operator
- ObserverCircuitBreaker<T> - Class in io.github.resilience4j.rxjava3.circuitbreaker.operator
- ObserverCircuitBreaker(Observable, CircuitBreaker) - Constructor for class io.github.resilience4j.rxjava3.circuitbreaker.operator.ObserverCircuitBreaker
- ObserverCircuitBreaker.CircuitBreakerObserver - Class in io.github.resilience4j.rxjava3.circuitbreaker.operator
- ObserverRateLimiter<T> - Class in io.github.resilience4j.rxjava3.ratelimiter.operator
- ObserverRateLimiter(Observable, RateLimiter) - Constructor for class io.github.resilience4j.rxjava3.ratelimiter.operator.ObserverRateLimiter
- ObserverRateLimiter.RateLimiterObserver - Class in io.github.resilience4j.rxjava3.ratelimiter.operator
- of(Bulkhead) - Static method in class io.github.resilience4j.rxjava3.bulkhead.operator.BulkheadOperator
-
Creates a BulkheadOperator.
- of(CircuitBreaker) - Static method in class io.github.resilience4j.rxjava3.circuitbreaker.operator.CircuitBreakerOperator
-
Creates a CircuitBreakerOperator.
- of(RateLimiter) - Static method in class io.github.resilience4j.rxjava3.ratelimiter.operator.RateLimiterOperator
-
Creates a RateLimiterOperator.
- of(Retry) - Static method in class io.github.resilience4j.rxjava3.retry.transformer.RetryTransformer
-
Creates a RetryOperator.
- of(TimeLimiter) - Static method in class io.github.resilience4j.rxjava3.timelimiter.transformer.TimeLimiterTransformer
-
Creates a TimeLimiterTransformer.
- onComplete() - Method in class io.github.resilience4j.rxjava3.AbstractCompletableObserver
- onComplete() - Method in class io.github.resilience4j.rxjava3.AbstractMaybeObserver
- onComplete() - Method in class io.github.resilience4j.rxjava3.AbstractObserver
- onComplete() - Method in class io.github.resilience4j.rxjava3.AbstractSubscriber
- onComplete() - Method in class io.github.resilience4j.rxjava3.retry.transformer.RetryTransformer.Context
- onError(Throwable) - Method in class io.github.resilience4j.rxjava3.AbstractCompletableObserver
- onError(Throwable) - Method in class io.github.resilience4j.rxjava3.AbstractMaybeObserver
- onError(Throwable) - Method in class io.github.resilience4j.rxjava3.AbstractObserver
- onError(Throwable) - Method in class io.github.resilience4j.rxjava3.AbstractSingleObserver
- onError(Throwable) - Method in class io.github.resilience4j.rxjava3.AbstractSubscriber
- onNext(T) - Method in class io.github.resilience4j.rxjava3.AbstractObserver
- onNext(T) - Method in class io.github.resilience4j.rxjava3.AbstractSubscriber
- onSubscribe(Disposable) - Method in class io.github.resilience4j.rxjava3.AbstractDisposable
- onSubscribe(Subscription) - Method in class io.github.resilience4j.rxjava3.AbstractSubscriber
- onSuccess(T) - Method in class io.github.resilience4j.rxjava3.AbstractMaybeObserver
- onSuccess(T) - Method in class io.github.resilience4j.rxjava3.AbstractSingleObserver
R
- rateLimiter - Variable in class io.github.resilience4j.rxjava3.ratelimiter.operator.CompletableRateLimiter
- rateLimiter - Variable in class io.github.resilience4j.rxjava3.ratelimiter.operator.FlowableRateLimiter
- rateLimiter - Variable in class io.github.resilience4j.rxjava3.ratelimiter.operator.MaybeRateLimiter
- rateLimiter - Variable in class io.github.resilience4j.rxjava3.ratelimiter.operator.ObserverRateLimiter
- rateLimiter - Variable in class io.github.resilience4j.rxjava3.ratelimiter.operator.RateLimiterOperator
- rateLimiter - Variable in class io.github.resilience4j.rxjava3.ratelimiter.operator.SingleRateLimiter
- RateLimiterCompletableObserver(CompletableObserver) - Constructor for class io.github.resilience4j.rxjava3.ratelimiter.operator.CompletableRateLimiter.RateLimiterCompletableObserver
- RateLimiterMaybeObserver(MaybeObserver) - Constructor for class io.github.resilience4j.rxjava3.ratelimiter.operator.MaybeRateLimiter.RateLimiterMaybeObserver
- RateLimiterObserver(Observer) - Constructor for class io.github.resilience4j.rxjava3.ratelimiter.operator.ObserverRateLimiter.RateLimiterObserver
- RateLimiterOperator<T> - Class in io.github.resilience4j.rxjava3.ratelimiter.operator
-
A RateLimiter operator which checks if a downstream subscriber/observer can acquire a permission to subscribe to an upstream Publisher.
- RateLimiterOperator(RateLimiter) - Constructor for class io.github.resilience4j.rxjava3.ratelimiter.operator.RateLimiterOperator
- RateLimiterSingleObserver(SingleObserver) - Constructor for class io.github.resilience4j.rxjava3.ratelimiter.operator.SingleRateLimiter.RateLimiterSingleObserver
- RateLimiterSubscriber(Subscriber) - Constructor for class io.github.resilience4j.rxjava3.ratelimiter.operator.FlowableRateLimiter.RateLimiterSubscriber
- request(long) - Method in class io.github.resilience4j.rxjava3.AbstractSubscriber
- retry - Variable in class io.github.resilience4j.rxjava3.retry.transformer.RetryTransformer
- retryContext - Variable in class io.github.resilience4j.rxjava3.retry.transformer.RetryTransformer.Context
- RetryDueToResultException(long) - Constructor for exception class io.github.resilience4j.rxjava3.retry.transformer.RetryTransformer.Context.RetryDueToResultException
- RetryTransformer<T> - Class in io.github.resilience4j.rxjava3.retry.transformer
- RetryTransformer(Retry) - Constructor for class io.github.resilience4j.rxjava3.retry.transformer.RetryTransformer
- RetryTransformer.Context<T> - Class in io.github.resilience4j.rxjava3.retry.transformer
- RetryTransformer.Context.RetryDueToResultException - Exception Class in io.github.resilience4j.rxjava3.retry.transformer
- RxJava3Adapter - Class in io.github.resilience4j.rxjava3.adapter
- RxJava3Adapter() - Constructor for class io.github.resilience4j.rxjava3.adapter.RxJava3Adapter
S
- SingleBulkhead<T> - Class in io.github.resilience4j.rxjava3.bulkhead.operator
- SingleBulkhead(Single, Bulkhead) - Constructor for class io.github.resilience4j.rxjava3.bulkhead.operator.SingleBulkhead
- SingleBulkhead.BulkheadSingleObserver - Class in io.github.resilience4j.rxjava3.bulkhead.operator
- SingleCircuitBreaker<T> - Class in io.github.resilience4j.rxjava3.circuitbreaker.operator
- SingleCircuitBreaker(Single, CircuitBreaker) - Constructor for class io.github.resilience4j.rxjava3.circuitbreaker.operator.SingleCircuitBreaker
- SingleCircuitBreaker.CircuitBreakerSingleObserver - Class in io.github.resilience4j.rxjava3.circuitbreaker.operator
- SingleRateLimiter<T> - Class in io.github.resilience4j.rxjava3.ratelimiter.operator
- SingleRateLimiter(Single, RateLimiter) - Constructor for class io.github.resilience4j.rxjava3.ratelimiter.operator.SingleRateLimiter
- SingleRateLimiter.RateLimiterSingleObserver - Class in io.github.resilience4j.rxjava3.ratelimiter.operator
- start - Variable in class io.github.resilience4j.rxjava3.circuitbreaker.operator.CompletableCircuitBreaker.CircuitBreakerCompletableObserver
- start - Variable in class io.github.resilience4j.rxjava3.circuitbreaker.operator.FlowableCircuitBreaker.CircuitBreakerSubscriber
- start - Variable in class io.github.resilience4j.rxjava3.circuitbreaker.operator.MaybeCircuitBreaker.CircuitBreakerMaybeObserver
- start - Variable in class io.github.resilience4j.rxjava3.circuitbreaker.operator.ObserverCircuitBreaker.CircuitBreakerObserver
- start - Variable in class io.github.resilience4j.rxjava3.circuitbreaker.operator.SingleCircuitBreaker.CircuitBreakerSingleObserver
- subscribeActual(CompletableObserver) - Method in class io.github.resilience4j.rxjava3.bulkhead.operator.CompletableBulkhead
- subscribeActual(CompletableObserver) - Method in class io.github.resilience4j.rxjava3.circuitbreaker.operator.CompletableCircuitBreaker
- subscribeActual(CompletableObserver) - Method in class io.github.resilience4j.rxjava3.ratelimiter.operator.CompletableRateLimiter
- subscribeActual(MaybeObserver) - Method in class io.github.resilience4j.rxjava3.bulkhead.operator.MaybeBulkhead
- subscribeActual(MaybeObserver) - Method in class io.github.resilience4j.rxjava3.circuitbreaker.operator.MaybeCircuitBreaker
- subscribeActual(MaybeObserver) - Method in class io.github.resilience4j.rxjava3.ratelimiter.operator.MaybeRateLimiter
- subscribeActual(Observer) - Method in class io.github.resilience4j.rxjava3.bulkhead.operator.ObserverBulkhead
- subscribeActual(Observer) - Method in class io.github.resilience4j.rxjava3.circuitbreaker.operator.ObserverCircuitBreaker
- subscribeActual(Observer) - Method in class io.github.resilience4j.rxjava3.ratelimiter.operator.ObserverRateLimiter
- subscribeActual(SingleObserver) - Method in class io.github.resilience4j.rxjava3.bulkhead.operator.SingleBulkhead
- subscribeActual(SingleObserver) - Method in class io.github.resilience4j.rxjava3.circuitbreaker.operator.SingleCircuitBreaker
- subscribeActual(SingleObserver) - Method in class io.github.resilience4j.rxjava3.ratelimiter.operator.SingleRateLimiter
- subscribeActual(Subscriber) - Method in class io.github.resilience4j.rxjava3.bulkhead.operator.FlowableBulkhead
- subscribeActual(Subscriber) - Method in class io.github.resilience4j.rxjava3.circuitbreaker.operator.FlowableCircuitBreaker
- subscribeActual(Subscriber) - Method in class io.github.resilience4j.rxjava3.ratelimiter.operator.FlowableRateLimiter
- subscription - Variable in class io.github.resilience4j.rxjava3.AbstractDisposable
- subscription - Variable in class io.github.resilience4j.rxjava3.AbstractSubscriber
T
- timeLimiter - Variable in class io.github.resilience4j.rxjava3.timelimiter.transformer.TimeLimiterTransformer
- TimeLimiterTransformer<T> - Class in io.github.resilience4j.rxjava3.timelimiter.transformer
- TimeLimiterTransformer(TimeLimiter) - Constructor for class io.github.resilience4j.rxjava3.timelimiter.transformer.TimeLimiterTransformer
- toFlowable(EventPublisher) - Static method in class io.github.resilience4j.rxjava3.adapter.RxJava3Adapter
-
Converts the EventPublisher into a Flowable.
- toObservable(EventPublisher) - Static method in class io.github.resilience4j.rxjava3.adapter.RxJava3Adapter
-
Converts the EventPublisher into an Observable.
- toString() - Method in class io.github.resilience4j.rxjava3.AbstractDisposable
- toString() - Method in class io.github.resilience4j.rxjava3.AbstractSubscriber
U
- upstream - Variable in class io.github.resilience4j.rxjava3.bulkhead.operator.CompletableBulkhead
- upstream - Variable in class io.github.resilience4j.rxjava3.bulkhead.operator.FlowableBulkhead
- upstream - Variable in class io.github.resilience4j.rxjava3.bulkhead.operator.MaybeBulkhead
- upstream - Variable in class io.github.resilience4j.rxjava3.bulkhead.operator.ObserverBulkhead
- upstream - Variable in class io.github.resilience4j.rxjava3.bulkhead.operator.SingleBulkhead
- upstream - Variable in class io.github.resilience4j.rxjava3.circuitbreaker.operator.CompletableCircuitBreaker
- upstream - Variable in class io.github.resilience4j.rxjava3.circuitbreaker.operator.FlowableCircuitBreaker
- upstream - Variable in class io.github.resilience4j.rxjava3.circuitbreaker.operator.MaybeCircuitBreaker
- upstream - Variable in class io.github.resilience4j.rxjava3.circuitbreaker.operator.ObserverCircuitBreaker
- upstream - Variable in class io.github.resilience4j.rxjava3.circuitbreaker.operator.SingleCircuitBreaker
- upstream - Variable in class io.github.resilience4j.rxjava3.ratelimiter.operator.CompletableRateLimiter
- upstream - Variable in class io.github.resilience4j.rxjava3.ratelimiter.operator.FlowableRateLimiter
- upstream - Variable in class io.github.resilience4j.rxjava3.ratelimiter.operator.MaybeRateLimiter
- upstream - Variable in class io.github.resilience4j.rxjava3.ratelimiter.operator.ObserverRateLimiter
- upstream - Variable in class io.github.resilience4j.rxjava3.ratelimiter.operator.SingleRateLimiter
W
- waitDurationMillis - Variable in exception class io.github.resilience4j.rxjava3.retry.transformer.RetryTransformer.Context.RetryDueToResultException
- whenNotCompleted(Runnable) - Method in class io.github.resilience4j.rxjava3.AbstractDisposable
- whenNotDisposed(Runnable) - Method in class io.github.resilience4j.rxjava3.AbstractDisposable
All Classes and Interfaces|All Packages