A B C D E F I J M N O R S T W Z

A

AbstractRetry<T,S> - Class in reactor.retry

allBut(Class<? extends Throwable>...) - Static method in interface reactor.retry.Retry

Returns a retry function that retries errors resulting from all exceptions except the specified non-retriable exceptions.

any() - Static method in interface reactor.retry.Retry

Returns a retry function that retries any exception.

anyOf(Class<? extends Throwable>...) - Static method in interface reactor.retry.Retry

Returns a retry function that retries errors resulting from any of the specified exceptions.

applicationContext() - Method in interface reactor.retry.Context

Application context that may be used to perform any rollbacks before a retry.

applicationContext() - Method in class reactor.retry.DefaultContext

apply(Flux<Long>) - Method in class reactor.retry.DefaultRepeat

apply(Flux<Throwable>) - Method in class reactor.retry.DefaultRetry

apply(Publisher<S>) - Method in interface reactor.retry.Repeat

Transforms the source into a repeating Flux based on the properties configured for this function.

apply(Publisher<S>) - Method in interface reactor.retry.Retry

Transforms the source into a retrying Flux based on the properties configured for this function.

averageDouble(Publisher<? extends Number>) - Static method in class reactor.math.MathFlux

Computes the double average of items in the source.

averageDouble(Publisher<T>, Function<? super T, ? extends Number>) - Static method in class reactor.math.MathFlux

Computes the double average of items in the source, which are mapped to numerical values using the provided mapping.

averageFloat(Publisher<? extends Number>) - Static method in class reactor.math.MathFlux

Computes the float average of items in the source.

averageFloat(Publisher<T>, Function<? super T, ? extends Number>) - Static method in class reactor.math.MathFlux

Computes the float average of items in the source, which are mapped to numerical values using the provided mapping.

B

Backoff - Interface in reactor.retry

Backoff function

backoff() - Method in interface reactor.retry.Context

The backoff delay.

backoff() - Method in class reactor.retry.DefaultContext

backoff(Backoff) - Method in class reactor.retry.DefaultRepeat

backoff(Backoff) - Method in class reactor.retry.DefaultRetry

backoff(Backoff) - Method in interface reactor.retry.Repeat

Returns a repeat function with backoff delay.

backoff(Backoff) - Method in interface reactor.retry.Retry

Returns a retry function with backoff delay.

BackoffDelay - Class in reactor.retry

BackoffDelay(Duration) - Constructor for class reactor.retry.BackoffDelay

BackoffDelay(Duration, Duration, Duration) - Constructor for class reactor.retry.BackoffDelay

C

companionValue() - Method in class reactor.retry.DefaultContext

companionValue() - Method in interface reactor.retry.RepeatContext

Returns the value provided in the companion Flux for repeats.

Context<T> - Interface in reactor.retry

Context provided to retry or repeat callbacks.

create(Predicate<? super RepeatContext<T>>, int) - Static method in class reactor.retry.DefaultRepeat

create(Predicate<? super RetryContext<T>>) - Static method in class reactor.retry.DefaultRetry

create() - Static method in class reactor.swing.SwingScheduler

createWorker() - Method in class reactor.swing.SwingScheduler

createWorker() - Method in class reactor.swing.SwtScheduler

D

DefaultContext<T> - Class in reactor.retry

DefaultContext(T, long, BackoffDelay, long) - Constructor for class reactor.retry.DefaultContext

DefaultContext(T, long, BackoffDelay, Throwable) - Constructor for class reactor.retry.DefaultContext

DefaultRepeat<T> - Class in reactor.retry

DefaultRetry<T> - Class in reactor.retry

delay() - Method in class reactor.retry.BackoffDelay

doOnRepeat(Consumer<? super RepeatContext<T>>) - Method in class reactor.retry.DefaultRepeat

doOnRepeat(Consumer<? super RepeatContext<T>>) - Method in interface reactor.retry.Repeat

Returns a repeat function that invokes the provided onRepeat callback before every repeat.

doOnRetry(Consumer<? super RetryContext<T>>) - Method in class reactor.retry.DefaultRetry

doOnRetry(Consumer<? super RetryContext<T>>) - Method in interface reactor.retry.Retry

Returns a retry function that invokes the provided onRetry callback before every retry.

E

exception() - Method in class reactor.retry.DefaultContext

exception() - Method in interface reactor.retry.RetryContext

Returns the exception from the last iteration.

exponential(Duration, Duration, int, boolean) - Static method in interface reactor.retry.Backoff

Backoff function with exponential backoff delay.

exponentialBackoff(Duration, Duration) - Method in interface reactor.retry.Repeat

Returns a repeat function with exponential backoff delay.

exponentialBackoff(Duration, Duration) - Method in interface reactor.retry.Retry

Returns a retry function with exponential backoff delay.

exponentialBackoffWithJitter(Duration, Duration) - Method in interface reactor.retry.Repeat

Returns a repeat function with full jitter backoff strategy.

exponentialBackoffWithJitter(Duration, Duration) - Method in interface reactor.retry.Retry

Returns a retry function with full jitter backoff strategy.

F

fixed(Duration) - Static method in interface reactor.retry.Backoff

Backoff function with fixed backoff delay

fixedBackoff(Duration) - Method in interface reactor.retry.Repeat

Returns a repeat function with fixed backoff delay.

fixedBackoff(Duration) - Method in interface reactor.retry.Retry

Returns a retry function with fixed backoff delay.

from(Display) - Static method in class reactor.swing.SwtScheduler

I

iteration() - Method in interface reactor.retry.Context

The next iteration number.

iteration() - Method in class reactor.retry.DefaultContext

J

jitter(Jitter) - Method in class reactor.retry.DefaultRepeat

jitter(Jitter) - Method in class reactor.retry.DefaultRetry

Jitter - Interface in reactor.retry

Jitter function that is applied to the backoff delay.

jitter(Jitter) - Method in interface reactor.retry.Repeat

Returns a repeat function that applies jitter to the backoff delay.

jitter(Jitter) - Method in interface reactor.retry.Retry

Returns a retry function that applies jitter to the backoff delay.

M

MathFlux - Class in reactor.math

Mathematical utilities that compute sum, average, minimum or maximum values from numerical sources or sources that can be mapped to numerical values using custom mappings.

MathFlux() - Constructor for class reactor.math.MathFlux

max(Publisher<T>) - Static method in class reactor.math.MathFlux

Computes the maximum value of items in the source.

max(Publisher<T>, Comparator<? super T>) - Static method in class reactor.math.MathFlux

Computes the maximum value of items in the source.

maxDelay() - Method in class reactor.retry.BackoffDelay

min(Publisher<T>) - Static method in class reactor.math.MathFlux

Computes the minimum value of items in the source.

min(Publisher<T>, Comparator<? super T>) - Static method in class reactor.math.MathFlux

Computes the minimum value of items in the source.

minDelay() - Method in class reactor.retry.BackoffDelay

N

noBackoff() - Method in interface reactor.retry.Repeat

Returns a repeat function with no backoff delay.

noBackoff() - Method in interface reactor.retry.Retry

Returns a retry function with no backoff delay.

noJitter() - Static method in interface reactor.retry.Jitter

Jitter function that is a no-op.

O

once() - Static method in interface reactor.retry.Repeat

Repeat function that repeats once.

onlyIf(Predicate<? super RepeatContext<T>>) - Static method in interface reactor.retry.Repeat

Repeat function that repeats only if the predicate returns true.

onlyIf(Predicate<? super RetryContext<T>>) - Static method in interface reactor.retry.Retry

Retry function that retries only if the predicate returns true.

R

random() - Static method in interface reactor.retry.Jitter

Jitter function that applies a random jitter to choose a random backoff delay between BackoffDelay.minDelay() and BackoffDelay.delay().

randomBackoff(Duration, Duration) - Method in interface reactor.retry.Repeat

Returns a repeat function with random de-correlated jitter backoff strategy.

randomBackoff(Duration, Duration) - Method in interface reactor.retry.Retry

Returns a retry function with random de-correlated jitter backoff strategy.

reactor.math - package reactor.math

reactor.retry - package reactor.retry

reactor.swing - package reactor.swing

Repeat<T> - Interface in reactor.retry

Repeat function that may be used with Flux.repeatWhen(Function), Mono.repeatWhen(Function) and Mono.repeatWhenEmpty(Function).

RepeatContext<T> - Interface in reactor.retry

Context provided to repeat predicate Repeat.onlyIf(java.util.function.Predicate) and the repeat callback Repeat.doOnRepeat(java.util.function.Consumer).

Retry<T> - Interface in reactor.retry

Retry function that may be used with Flux.retryWhen(Function) and Mono.retryWhen(Function).

RetryContext<T> - Interface in reactor.retry

Context provided to retry predicate Retry.onlyIf(java.util.function.Predicate) and the retry callback Retry.doOnRetry(java.util.function.Consumer).

RetryExhaustedException - Exception in reactor.retry

Exception indicating that retries have been exhausted after Retry.timeout(java.time.Duration) or Retry.retryMax(int).

RetryExhaustedException() - Constructor for exception reactor.retry.RetryExhaustedException

RetryExhaustedException(String, Throwable, boolean, boolean) - Constructor for exception reactor.retry.RetryExhaustedException

RetryExhaustedException(String, Throwable) - Constructor for exception reactor.retry.RetryExhaustedException

RetryExhaustedException(String) - Constructor for exception reactor.retry.RetryExhaustedException

RetryExhaustedException(Throwable) - Constructor for exception reactor.retry.RetryExhaustedException

retryMax(int) - Method in class reactor.retry.DefaultRetry

retryMax(int) - Method in interface reactor.retry.Retry

Retry function that retries n times.

retryOnce() - Method in interface reactor.retry.Retry

Retry function that retries once.

S

schedule(Runnable) - Method in class reactor.swing.SwingScheduler

schedule(Runnable, long, TimeUnit) - Method in class reactor.swing.SwingScheduler

schedule(Runnable) - Method in class reactor.swing.SwtScheduler

schedule(Runnable, long, TimeUnit) - Method in class reactor.swing.SwtScheduler

schedulePeriodically(Runnable, long, long, TimeUnit) - Method in class reactor.swing.SwingScheduler

schedulePeriodically(Runnable, long, long, TimeUnit) - Method in class reactor.swing.SwtScheduler

sumDouble(Publisher<? extends Number>) - Static method in class reactor.math.MathFlux

Computes the double sum of items in the source.

sumDouble(Publisher<T>, Function<? super T, ? extends Number>) - Static method in class reactor.math.MathFlux

Computes the double sum of items in the source, which are mapped to numerical values using the provided mapping.

sumFloat(Publisher<? extends Number>) - Static method in class reactor.math.MathFlux

Computes the float sum of items in the source.

sumFloat(Publisher<T>, Function<? super T, ? extends Number>) - Static method in class reactor.math.MathFlux

Computes the float sum of items in the source, which are mapped to numerical values using the provided mapping.

sumInt(Publisher<? extends Number>) - Static method in class reactor.math.MathFlux

Computes the integer sum of items in the source.

sumInt(Publisher<T>, Function<? super T, ? extends Number>) - Static method in class reactor.math.MathFlux

Computes the integer sum of items in the source, which are mapped to numerical values using the provided mapping.

sumLong(Publisher<? extends Number>) - Static method in class reactor.math.MathFlux

Computes the long sum of items in the source.

sumLong(Publisher<T>, Function<? super T, ? extends Number>) - Static method in class reactor.math.MathFlux

Computes the long sum of items in the source, which are mapped to numerical values using the provided mapping.

SwingScheduler - Class in reactor.swing

Scheduler that runs tasks on Swing's event dispatch thread.

SwtScheduler - Class in reactor.swing

Scheduler that runs tasks on Swt's event dispatch thread.

T

timeout(Duration) - Method in class reactor.retry.DefaultRepeat

timeout(Duration) - Method in class reactor.retry.DefaultRetry

timeout(Duration) - Method in interface reactor.retry.Repeat

Returns a repeat function with timeout.

timeout(Duration) - Method in interface reactor.retry.Retry

Returns a retry function with timeout.

times(int) - Static method in interface reactor.retry.Repeat

Repeat function that repeats n times.

toString() - Method in class reactor.retry.DefaultContext

W

withApplicationContext(T) - Method in class reactor.retry.DefaultRepeat

withApplicationContext(T) - Method in class reactor.retry.DefaultRetry

withApplicationContext(T) - Method in interface reactor.retry.Repeat

Returns a repeat function with an application context that may be used to perform any rollbacks before a repeat.

withApplicationContext(T) - Method in interface reactor.retry.Retry

Returns a retry function with an application context that may be used to perform any rollbacks before a retry.

withBackoffScheduler(Scheduler) - Method in class reactor.retry.DefaultRepeat

withBackoffScheduler(Scheduler) - Method in class reactor.retry.DefaultRetry

withBackoffScheduler(Scheduler) - Method in interface reactor.retry.Repeat

Returns a repeat function that uses the scheduler provided for backoff delays.

withBackoffScheduler(Scheduler) - Method in interface reactor.retry.Retry

Returns a retry function that uses the scheduler provided for backoff delays.

Z

zero() - Static method in interface reactor.retry.Backoff

Backoff function with no backoff delay

ZERO_BACKOFF - Static variable in interface reactor.retry.Backoff

A B C D E F I J M N O R S T W Z