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

A

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.

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

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

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.

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

Computes the BigDecimal average of items in the source.

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

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

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

Computes the BigInteger average of items in the source.

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

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

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

BooleanUtils - Class in reactor.bool

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

C

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

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

D

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

E

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

F

ForkJoinPoolScheduler - Class in reactor.scheduler.forkjoin

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

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.

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

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.

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.

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.

N

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

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

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

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.

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

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

P

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

reactor.bool - package reactor.bool

reactor.function - package reactor.function

reactor.math - package reactor.math

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

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

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

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

S

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

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

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

SchedulerClock - Class in reactor.scheduler.clock

Clock adapter around Scheduler.

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

Computes the BigDecimal sum of items in the source.

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

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

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

Computes the BigInteger sum of items in the source.

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

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

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.

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.

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

TupleUtils - Class in reactor.function

W

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

X

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

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

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