Skip navigation links
Reactor Addons: javadoc
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 
Skip navigation links
Reactor Addons: javadoc