A B C D E F G H I J L M N O P R S T W X Y Z

A

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

accept(T1, T2, T3) - Method in interface reactor.function.Consumer3

Performs this operation on the given arguments.

accept(T1, T2, T3, T4) - Method in interface reactor.function.Consumer4

Performs this operation on the given arguments.

accept(T1, T2, T3, T4, T5) - Method in interface reactor.function.Consumer5

Performs this operation on the given arguments.

accept(T1, T2, T3, T4, T5, T6) - Method in interface reactor.function.Consumer6

Performs this operation on the given arguments.

accept(T1, T2, T3, T4, T5, T6, T7) - Method in interface reactor.function.Consumer7

Performs this operation on the given arguments.

accept(T1, T2, T3, T4, T5, T6, T7, T8) - Method in interface reactor.function.Consumer8

Performs this operation on the given arguments.

alert() - Static method in class reactor.extra.processor.WaitStrategy

Throw an Alert signal exception (singleton) that can be checked against WaitStrategy.isAlert(Throwable)

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, once.

and(Mono<Boolean>, Mono<Boolean>) - Static method in class reactor.bool.BooleanUtils

Two booleans, wrapped in Mono, combined with the AND operator.

andWriteWith(BiFunction<KEY, List<Signal<VALUE>>, Mono<Void>>) - Method in interface reactor.cache.CacheFlux.FluxCacheBuilderCacheWriter

Set up the cache writer BiFunction to use to store the source data into the cache in case of cache miss.

andWriteWith(BiFunction<KEY, Signal<? extends VALUE>, Mono<Void>>) - Method in interface reactor.cache.CacheMono.MonoCacheBuilderCacheWriter

Set up the cache writer BiFunction to use to store the source data into the cache in case of cache miss.

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

Returns a retry function that retries any exception, once.

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, once.

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

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

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

apply(T1, T2, T3) - Method in interface reactor.function.Function3

Applies this function to the given arguments.

apply(T1, T2, T3, T4) - Method in interface reactor.function.Function4

Applies this function to the given arguments.

apply(T1, T2, T3, T4, T5) - Method in interface reactor.function.Function5

Applies this function to the given arguments.

apply(T1, T2, T3, T4, T5, T6) - Method in interface reactor.function.Function6

Applies this function to the given arguments.

apply(T1, T2, T3, T4, T5, T6, T7) - Method in interface reactor.function.Function7

Applies this function to the given arguments.

apply(T1, T2, T3, T4, T5, T6, T7, T8) - Method in interface reactor.function.Function8

Applies this function to the given arguments.

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.

autoCancel(boolean) - Method in class reactor.extra.processor.TopicProcessor.Builder

Configures auto-cancel for this builder.

autoCancel(boolean) - Method in class reactor.extra.processor.WorkQueueProcessor.Builder

Configures auto-cancel for this builder.

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 class reactor.retry.DefaultContext

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

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

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

The backoff delay.

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

blocking() - Static method in class reactor.extra.processor.WaitStrategy

Blocking strategy that uses a lock and condition variable for consumer waiting on a barrier.

BooleanUtils - Class in reactor.bool

Functions to help compose results with Mono-wrapped boolean values.

bufferSize(int) - Method in class reactor.extra.processor.TopicProcessor.Builder

Configures buffer size for this builder.

bufferSize(int) - Method in class reactor.extra.processor.WorkQueueProcessor.Builder

Configures buffer size for this builder.

build() - Method in class reactor.extra.processor.TopicProcessor.Builder

Creates a new TopicProcessor using the properties of this builder.

build() - Method in class reactor.extra.processor.WorkQueueProcessor.Builder

Creates a new WorkQueueProcessor using the properties of this builder.

builder() - Static method in class reactor.extra.processor.TopicProcessor

Create a new TopicProcessor TopicProcessor.Builder with default properties.

builder() - Static method in class reactor.extra.processor.WorkQueueProcessor

Create a new WorkQueueProcessor WorkQueueProcessor.Builder with default properties.

busySpin() - Static method in class reactor.extra.processor.WaitStrategy

Busy Spin strategy that uses a busy spin loop for consumers waiting on a barrier.

C

CacheFlux - Class in reactor.cache

Opinionated caching helper that defines how to store and restore a Flux in an arbitrary cache abstraction.

CacheFlux() - Constructor for class reactor.cache.CacheFlux

CacheFlux.FluxCacheBuilderCacheMiss<KEY,VALUE> - Interface in reactor.cache

Setup original source to fallback to in case of cache miss.

CacheFlux.FluxCacheBuilderCacheWriter<KEY,VALUE> - Interface in reactor.cache

Set up the cache writer BiFunction to use to store the source data into the cache in case of cache miss.

CacheFlux.FluxCacheBuilderMapMiss<VALUE> - Interface in reactor.cache

Setup original source to fallback to in case of cache miss and return a wrapped Flux that transparently looks up data from a Map representation of a cache and store data into the cache in case of cache miss.

CacheMono - Class in reactor.cache

Opinionated caching helper that defines how to store and restore a Mono in an arbitrary cache abstraction.

CacheMono() - Constructor for class reactor.cache.CacheMono

CacheMono.MonoCacheBuilderCacheMiss<KEY,VALUE> - Interface in reactor.cache

Setup original source to fallback to in case of cache miss.

CacheMono.MonoCacheBuilderCacheWriter<KEY,VALUE> - Interface in reactor.cache

Set up the cache writer BiFunction to use to store the source data into the cache in case of cache miss.

CacheMono.MonoCacheBuilderMapMiss<VALUE> - Interface in reactor.cache

Setup original source to fallback to in case of cache miss and return a wrapped Mono that transparently looks up data from a Map representation of a cache and store data into the cache in case of cache miss.

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

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

Returns the value provided in the companion Flux for repeats.

consumer(BiConsumer<T1, T2>) - Static method in class reactor.function.TupleUtils

Returns a Consumer of Tuple2 that wraps a consumer of the component values of the tuple

consumer(Consumer3<T1, T2, T3>) - Static method in class reactor.function.TupleUtils

Returns a Consumer of Tuple3 that wraps a consumer of the component values of the tuple

consumer(Consumer4<T1, T2, T3, T4>) - Static method in class reactor.function.TupleUtils

Returns a Consumer of Tuple4 that wraps a consumer of the component values of the tuple

consumer(Consumer5<T1, T2, T3, T4, T5>) - Static method in class reactor.function.TupleUtils

Returns a Consumer of Tuple5 that wraps a consumer of the component values of the tuple

consumer(Consumer6<T1, T2, T3, T4, T5, T6>) - Static method in class reactor.function.TupleUtils

Returns a Consumer of Tuple6 that wraps a consumer of the component values of the tuple

consumer(Consumer7<T1, T2, T3, T4, T5, T6, T7>) - Static method in class reactor.function.TupleUtils

Returns a Consumer of Tuple7 that wraps a consumer of the component values of the tuple

consumer(Consumer8<T1, T2, T3, T4, T5, T6, T7, T8>) - Static method in class reactor.function.TupleUtils

Returns a Consumer of Tuple8 that wraps a consumer of the component values of the tuple

Consumer3<T1,T2,T3> - Interface in reactor.function

An operation that accepts three input arguments and returns no result.

Consumer4<T1,T2,T3,T4> - Interface in reactor.function

An operation that accepts four input arguments and returns no result.

Consumer5<T1,T2,T3,T4,T5> - Interface in reactor.function

An operation that accepts five input arguments and returns no result.

Consumer6<T1,T2,T3,T4,T5,T6> - Interface in reactor.function

An operation that accepts six input arguments and returns no result.

Consumer7<T1,T2,T3,T4,T5,T6,T7> - Interface in reactor.function

An operation that accepts seven input arguments and returns no result.

Consumer8<T1,T2,T3,T4,T5,T6,T7,T8> - Interface in reactor.function

An operation that accepts eight input arguments and returns no result.

create() - Static method in class reactor.extra.processor.TopicProcessor

Create a new TopicProcessor using Queues.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy and auto-cancel.

create(String, int) - Static method in class reactor.extra.processor.TopicProcessor

Create a new TopicProcessor using the provided backlog size, with a blockingWait Strategy and auto-cancellation.

create() - Static method in class reactor.extra.processor.WorkQueueProcessor

Create a new WorkQueueProcessor using Queues.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy and auto-cancel.

create(String, int) - Static method in class reactor.extra.processor.WorkQueueProcessor

Create a new WorkQueueProcessor using the passed buffer size, blockingWait Strategy and auto-cancel.

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

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

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

Repeat function that repeats n times, only if the predicate returns true.

create(String) - Static method in class reactor.scheduler.forkjoin.ForkJoinPoolScheduler

Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work.

create(String, int) - Static method in class reactor.scheduler.forkjoin.ForkJoinPoolScheduler

Scheduler that utilizes a ForkJoinPool for workers and is suited for parallel work.

create(int, ForkJoinPool.ForkJoinWorkerThreadFactory, Scheduler) - Static method in class reactor.scheduler.forkjoin.ForkJoinPoolScheduler

Scheduler that utilizes a ForkJoinPool for workers and is suited for parallel work.

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

createWorker() - Method in class reactor.scheduler.forkjoin.ForkJoinPoolScheduler

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

dispose() - Method in class reactor.scheduler.forkjoin.ForkJoinPoolScheduler

doComplete() - Method in class reactor.extra.processor.TopicProcessor

doComplete() - Method in class reactor.extra.processor.WorkQueueProcessor

doError(Throwable) - Method in class reactor.extra.processor.TopicProcessor

doError(Throwable) - Method in class reactor.extra.processor.WorkQueueProcessor

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.

drain() - Method in class reactor.extra.processor.TopicProcessor

drain() - Method in class reactor.extra.processor.WorkQueueProcessor

E

equals(Object) - Method in class reactor.scheduler.clock.SchedulerClock

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

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

Returns the exception from the last iteration.

executor(ExecutorService) - Method in class reactor.extra.processor.TopicProcessor.Builder

Configures an ExecutorService to execute as many event-loop consuming the ringbuffer as subscribers.

executor(ExecutorService) - Method in class reactor.extra.processor.WorkQueueProcessor.Builder

Configures an ExecutorService to execute as many event-loop consuming the ringbuffer as subscribers.

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.

ForkJoinPoolScheduler - Class in reactor.scheduler.forkjoin

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

function(BiFunction<T1, T2, R>) - Static method in class reactor.function.TupleUtils

Returns a Function of Tuple2 that wraps a function of the component values of the tuple

function(Function3<T1, T2, T3, R>) - Static method in class reactor.function.TupleUtils

Returns a Function of Tuple3 that wraps a function of the component values of the tuple

function(Function4<T1, T2, T3, T4, R>) - Static method in class reactor.function.TupleUtils

Returns a Function of Tuple4 that wraps a function of the component values of the tuple

function(Function5<T1, T2, T3, T4, T5, R>) - Static method in class reactor.function.TupleUtils

Returns a Function of Tuple5 that wraps a function of the component values of the tuple

function(Function6<T1, T2, T3, T4, T5, T6, R>) - Static method in class reactor.function.TupleUtils

Returns a Function of Tuple6 that wraps a function of the component values of the tuple

function(Function7<T1, T2, T3, T4, T5, T6, T7, R>) - Static method in class reactor.function.TupleUtils

Returns a Function of Tuple7 that wraps a function of the component values of the tuple

function(Function8<T1, T2, T3, T4, T5, T6, T7, T8, R>) - Static method in class reactor.function.TupleUtils

Returns a Function of Tuple8 that wraps a function of the component values of the tuple

Function3<T1,T2,T3,R> - Interface in reactor.function

Represents a function that accepts three arguments and produces a result.

Function4<T1,T2,T3,T4,R> - Interface in reactor.function

Represents a function that accepts four arguments and produces a result.

Function5<T1,T2,T3,T4,T5,R> - Interface in reactor.function

Represents a function that accepts five arguments and produces a result.

Function6<T1,T2,T3,T4,T5,T6,R> - Interface in reactor.function

Represents a function that accepts six arguments and produces a result.

Function7<T1,T2,T3,T4,T5,T6,T7,R> - Interface in reactor.function

Represents a function that accepts seven arguments and produces a result.

Function8<T1,T2,T3,T4,T5,T6,T7,T8,R> - Interface in reactor.function

Represents a function that accepts eight arguments and produces a result.

G

getPending() - Method in class reactor.extra.processor.TopicProcessor

getPending() - Method in class reactor.extra.processor.WorkQueueProcessor

getScheduler() - Method in class reactor.scheduler.clock.SchedulerClock

Return wrapped Scheduler instance

getZone() - Method in class reactor.scheduler.clock.SchedulerClock

H

hashCode() - Method in class reactor.scheduler.clock.SchedulerClock

I

instant() - Method in class reactor.scheduler.clock.SchedulerClock

Gets the current instant of the clock.

isAlert(Throwable) - Static method in class reactor.extra.processor.WaitStrategy

Test if exception is alert

isDisposed() - Method in class reactor.scheduler.forkjoin.ForkJoinPoolScheduler

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

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

The next iteration number.

IterationContext<T> - Interface in reactor.retry

Context provided to retry or repeat callbacks.

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.

L

liteBlocking() - Static method in class reactor.extra.processor.WaitStrategy

Variation of the WaitStrategy.blocking() that attempts to elide conditional wake-ups when the lock is uncontended.

lookup(Map<KEY, ? super List>, KEY, Class<VALUE>) - Static method in class reactor.cache.CacheFlux

Restore a Flux<VALUE> from the cache-map given a provided key.

lookup(Function<KEY, Mono<List<Signal<VALUE>>>>, KEY) - Static method in class reactor.cache.CacheFlux

Restore a Flux<VALUE> from the cache reader Function given a provided key.

lookup(Map<KEY, ? super Signal<? extends VALUE>>, KEY) - Static method in class reactor.cache.CacheMono

Restore a Mono<VALUE> from the cache-map given a provided key.

lookup(Map<KEY, ? super Signal<? extends VALUE>>, KEY, Class<VALUE>) - Static method in class reactor.cache.CacheMono

Restore a Mono<VALUE> from the cache-map given a provided key.

lookup(Function<KEY, Mono<Signal<? extends VALUE>>>, KEY) - Static method in class reactor.cache.CacheMono

Restore a Mono<VALUE> from the reader Function (see below) given a provided key.

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

millis() - Method in class reactor.scheduler.clock.SchedulerClock

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

name(String) - Method in class reactor.extra.processor.TopicProcessor.Builder

Configures name for this builder.

name(String) - Method in class reactor.extra.processor.WorkQueueProcessor.Builder

Configures name for this builder.

nand(Mono<Boolean>, Mono<Boolean>) - Static method in class reactor.bool.BooleanUtils

Two booleans, wrapped in Mono, combined with the NOT-AND (NAND) operator.

NO_JITTER - Static variable in interface reactor.retry.Jitter

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.

nor(Mono<Boolean>, Mono<Boolean>) - Static method in class reactor.bool.BooleanUtils

Two booleans, wrapped in Mono, combined with the NOT-OR (NOR) operator.

not(Mono<Boolean>) - Static method in class reactor.bool.BooleanUtils

A boolean, wrapped in a Mono, inverted by the NOT operator.

O

of(Scheduler) - Static method in class reactor.scheduler.clock.SchedulerClock

Create instance of SchedulerClock from given Scheduler and system default ZoneId.systemDefault()

of(Scheduler, ZoneId) - Static method in class reactor.scheduler.clock.SchedulerClock

Create instance of SchedulerClock from given Scheduler and ZoneId

onCacheMissResume(Flux<VALUE>) - Method in interface reactor.cache.CacheFlux.FluxCacheBuilderCacheMiss

Setup original source to fallback to in case of cache miss.

onCacheMissResume(Supplier<Flux<VALUE>>) - Method in interface reactor.cache.CacheFlux.FluxCacheBuilderCacheMiss

Setup original source to fallback to in case of cache miss, through a Supplier which allows lazy resolution of the source.

onCacheMissResume(Flux<VALUE>) - Method in interface reactor.cache.CacheFlux.FluxCacheBuilderMapMiss

Setup original source to fallback to in case of cache miss.

onCacheMissResume(Supplier<Flux<VALUE>>) - Method in interface reactor.cache.CacheFlux.FluxCacheBuilderMapMiss

Setup original source to fallback to in case of cache miss, through a Supplier which allows lazy resolution of the source.

onCacheMissResume(Mono<VALUE>) - Method in interface reactor.cache.CacheMono.MonoCacheBuilderCacheMiss

Setup original source to fallback to in case of cache miss.

onCacheMissResume(Supplier<Mono<VALUE>>) - Method in interface reactor.cache.CacheMono.MonoCacheBuilderCacheMiss

Setup original source to fallback to in case of cache miss, through a Supplier which allows lazy resolution of the source.

onCacheMissResume(Mono<VALUE>) - Method in interface reactor.cache.CacheMono.MonoCacheBuilderMapMiss

Setup original source to fallback to in case of cache miss.

onCacheMissResume(Supplier<Mono<VALUE>>) - Method in interface reactor.cache.CacheMono.MonoCacheBuilderMapMiss

Setup original source to fallback to in case of cache miss, through a Supplier which allows lazy resolution of the source.

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

Repeat function that repeats once.

onHandleError(BiConsumer<Thread, ? super Throwable>) - Static method in class reactor.scheduler.forkjoin.ForkJoinPoolScheduler

Define a hook that is executed when a Scheduler has handled an error.

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, with no limit to the number of attempts.

or(Mono<Boolean>, Mono<Boolean>) - Static method in class reactor.bool.BooleanUtils

Two booleans, wrapped in Mono, combined with the OR operator.

P

parking() - Static method in class reactor.extra.processor.WaitStrategy

Parking strategy that initially spins, then uses a Thread.yield(), and eventually sleep (LockSupport.parkNanos(1)) for the minimum number of nanos the OS and JVM will allow while the consumers are waiting on a barrier.

parking(int) - Static method in class reactor.extra.processor.WaitStrategy

Parking strategy that initially spins, then uses a Thread.yield(), and eventually sleep (LockSupport.parkNanos(1)) for the minimum number of nanos the OS and JVM will allow while the consumers are waiting on a barrier.

phasedOff(long, long, TimeUnit, WaitStrategy) - Static method in class reactor.extra.processor.WaitStrategy

Phased wait strategy for waiting consumers on a barrier.

phasedOffLiteLock(long, long, TimeUnit) - Static method in class reactor.extra.processor.WaitStrategy

Block with wait/notifyAll semantics

phasedOffLock(long, long, TimeUnit) - Static method in class reactor.extra.processor.WaitStrategy

Block with wait/notifyAll semantics

phasedOffSleep(long, long, TimeUnit) - Static method in class reactor.extra.processor.WaitStrategy

Block by parking in a loop

predicate(BiPredicate<T1, T2>) - Static method in class reactor.function.TupleUtils

Returns a Predicate of Tuple2 that wraps a predicate of the component values of the tuple

predicate(Predicate3<T1, T2, T3>) - Static method in class reactor.function.TupleUtils

Returns a Predicate of Tuple3 that wraps a predicate of the component values of the tuple

predicate(Predicate4<T1, T2, T3, T4>) - Static method in class reactor.function.TupleUtils

Returns a Predicate of Tuple4 that wraps a predicate of the component values of the tuple

predicate(Predicate5<T1, T2, T3, T4, T5>) - Static method in class reactor.function.TupleUtils

Returns a Predicate of Tuple5 that wraps a predicate of the component values of the tuple

predicate(Predicate6<T1, T2, T3, T4, T5, T6>) - Static method in class reactor.function.TupleUtils

Returns a Predicate of Tuple6 that wraps a predicate of the component values of the tuple

predicate(Predicate7<T1, T2, T3, T4, T5, T6, T7>) - Static method in class reactor.function.TupleUtils

Returns a Predicate of Tuple7 that wraps a predicate of the component values of the tuple

predicate(Predicate8<T1, T2, T3, T4, T5, T6, T7, T8>) - Static method in class reactor.function.TupleUtils

Returns a Predicate of Tuple8 that wraps a predicate of the component values of the tuple

Predicate3<T1,T2,T3> - Interface in reactor.function

Represents a predicate (boolean-valued function) of three arguments.

Predicate4<T1,T2,T3,T4> - Interface in reactor.function

Represents a predicate (boolean-valued function) of four arguments.

Predicate5<T1,T2,T3,T4,T5> - Interface in reactor.function

Represents a predicate (boolean-valued function) of five arguments.

Predicate6<T1,T2,T3,T4,T5,T6> - Interface in reactor.function

Represents a predicate (boolean-valued function) of six arguments.

Predicate7<T1,T2,T3,T4,T5,T6,T7> - Interface in reactor.function

Represents a predicate (boolean-valued function) of seven arguments.

Predicate8<T1,T2,T3,T4,T5,T6,T7,T8> - Interface in reactor.function

Represents a predicate (boolean-valued function) of eight arguments.

R

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

Jitter function that applies a random jitter with a factor of 0.5, generating a backoff between [d - d*0.5; d + d*0.5] (but still within the limits of [BackoffDelay.minDelay(); BackoffDelay.maxDelay()].

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

Jitter function that applies a random jitter with a provided [0; 1] factor (default 0.5), generating a backoff between [d - d*factor; d + d*factor] (but still within the limits of [BackoffDelay.minDelay(); BackoffDelay.maxDelay()].

RANDOM_JITTER - Static variable in interface reactor.retry.Jitter

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.bool - package reactor.bool

reactor.cache - package reactor.cache

Extra utilities around caching, providing a default go-to strategy on what to store in a cache.

reactor.extra.processor - package reactor.extra.processor

reactor.function - package reactor.function

reactor.math - package reactor.math

reactor.retry - package reactor.retry

reactor.scheduler.clock - package reactor.scheduler.clock

reactor.scheduler.forkjoin - package reactor.scheduler.forkjoin

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).

repeatMax(long) - Method in class reactor.retry.DefaultRepeat

repeatMax(long) - Method in interface reactor.retry.Repeat

Returns a repeat function that repeats at most n times.

requestTask(Subscription) - Method in class reactor.extra.processor.TopicProcessor

requestTask(Subscription) - Method in class reactor.extra.processor.WorkQueueProcessor

requestTaskExecutor(ExecutorService) - Method in class reactor.extra.processor.TopicProcessor.Builder

Configures an additional ExecutorService that is used internally on each subscription.

requestTaskExecutor(ExecutorService) - Method in class reactor.extra.processor.WorkQueueProcessor.Builder

Configures an additional ExecutorService that is used internally on each subscription.

resetOnHandleError() - Static method in class reactor.scheduler.forkjoin.ForkJoinPoolScheduler

Reset the ForkJoinPoolScheduler.onHandleError(BiConsumer) hook to the default no-op behavior.

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(long) - Method in class reactor.retry.DefaultRetry

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

Retry function that retries n times.

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

Retry function that retries once.

run() - Method in class reactor.extra.processor.TopicProcessor

run() - Method in class reactor.extra.processor.WorkQueueProcessor

S

schedule(Runnable) - Method in class reactor.scheduler.forkjoin.ForkJoinPoolScheduler

schedule(Runnable, long, TimeUnit) - Method in class reactor.scheduler.forkjoin.ForkJoinPoolScheduler

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.scheduler.forkjoin.ForkJoinPoolScheduler

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

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

SchedulerClock - Class in reactor.scheduler.clock

Clock adapter around Scheduler.

share(boolean) - Method in class reactor.extra.processor.TopicProcessor.Builder

Configures sharing state for this builder.

share(String, int) - Static method in class reactor.extra.processor.TopicProcessor

Create a new shared TopicProcessor using the passed backlog size, with a blockingWait Strategy and auto-cancellation.

share(boolean) - Method in class reactor.extra.processor.WorkQueueProcessor.Builder

Configures sharing state for this builder.

share(String, int) - Static method in class reactor.extra.processor.WorkQueueProcessor

Create a new shared WorkQueueProcessor using the passed buffer size, blockingWait Strategy and auto-cancel.

signalAllWhenBlocking() - Method in class reactor.extra.processor.WaitStrategy

Implementations should signal the waiting consumers that the cursor has advanced.

signalSupplier(Supplier<T>) - Method in class reactor.extra.processor.TopicProcessor.Builder

Configures a supplier of dispatched signals to preallocate in the ring buffer

sleeping() - Static method in class reactor.extra.processor.WaitStrategy

Yielding strategy that uses a Thread.sleep(1) for consumers waiting on a barrier after an initially spinning.

subscribe(CoreSubscriber<? super E>) - Method in class reactor.extra.processor.TopicProcessor

subscribe(CoreSubscriber<? super E>) - Method in class reactor.extra.processor.WorkQueueProcessor

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

test(T1, T2, T3) - Method in interface reactor.function.Predicate3

Evaluates this predicate on the given arguments.

test(T1, T2, T3, T4) - Method in interface reactor.function.Predicate4

Evaluates this predicate on the given arguments.

test(T1, T2, T3, T4, T5) - Method in interface reactor.function.Predicate5

Evaluates this predicate on the given arguments.

test(T1, T2, T3, T4, T5, T6) - Method in interface reactor.function.Predicate6

Evaluates this predicate on the given arguments.

test(T1, T2, T3, T4, T5, T6, T7) - Method in interface reactor.function.Predicate7

Evaluates this predicate on the given arguments.

test(T1, T2, T3, T4, T5, T6, T7, T8) - Method in interface reactor.function.Predicate8

Evaluates this predicate on the given arguments.

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(long) - Static method in interface reactor.retry.Repeat

Repeat function that repeats n times.

TopicProcessor<E> - Class in reactor.extra.processor

An implementation of a RingBuffer backed message-passing Processor implementing publish-subscribe with async event loops.

TopicProcessor.Builder<T> - Class in reactor.extra.processor

TopicProcessor builder that can be used to create new processors.

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

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

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

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

toString() - Method in class reactor.scheduler.clock.SchedulerClock

TupleUtils - Class in reactor.function

W

waitFor(long, LongSupplier, Runnable) - Method in class reactor.extra.processor.WaitStrategy

Wait for the given sequence to be available.

waitStrategy(WaitStrategy) - Method in class reactor.extra.processor.TopicProcessor.Builder

Configures wait strategy for this builder.

WaitStrategy - Class in reactor.extra.processor

Strategy employed to wait for specific LongSupplier values with various spinning strategies.

WaitStrategy() - Constructor for class reactor.extra.processor.WaitStrategy

waitStrategy(WaitStrategy) - Method in class reactor.extra.processor.WorkQueueProcessor.Builder

Configures wait strategy for this builder.

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.

withScheduler(Scheduler) - Method in class reactor.scheduler.clock.SchedulerClock

Builder method that returns new instance of SchedulerClock which is constructed from old ZoneId and passed Scheduler instance

withZone(ZoneId) - Method in class reactor.scheduler.clock.SchedulerClock

WorkQueueProcessor<E> - Class in reactor.extra.processor

An implementation of a RingBuffer backed message-passing Processor implementing work-queue distribution with async event loops.

WorkQueueProcessor.Builder<T> - Class in reactor.extra.processor

WorkQueueProcessor builder that can be used to create new processors.

X

xor(Mono<Boolean>, Mono<Boolean>) - Static method in class reactor.bool.BooleanUtils

Two booleans, wrapped in Mono, combined with the exclusive-OR operator.

Y

yielding() - Static method in class reactor.extra.processor.WaitStrategy

Yielding strategy that uses a Thread.yield() for consumers waiting on a barrier after an initially spinning.

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 G H I J L M N O P R S T W X Y Z