reactor.math

Class MathFlux

java.lang.Object

reactor.math.MathFlux

public final class MathFlux
extends java.lang.Object

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. Minimum and maximum values can be computed for any source containing Comparable values or using custom @link Comparator.

Constructor Summary

Constructors

Constructor and Description
MathFlux()

Method Summary

Modifier and Type	Method and Description
static reactor.core.publisher.Mono<java.lang.Double>	averageDouble(Publisher<? extends java.lang.Number> source) Computes the double average of items in the source.
static <T> reactor.core.publisher.Mono<java.lang.Double>	averageDouble(Publisher<T> source, java.util.function.Function<? super T,? extends java.lang.Number> mapping) Computes the double average of items in the source, which are mapped to numerical values using the provided mapping.
static reactor.core.publisher.Mono<java.lang.Float>	averageFloat(Publisher<? extends java.lang.Number> source) Computes the float average of items in the source.
static <T> reactor.core.publisher.Mono<java.lang.Float>	averageFloat(Publisher<T> source, java.util.function.Function<? super T,? extends java.lang.Number> mapping) Computes the float average of items in the source, which are mapped to numerical values using the provided mapping.
static <T extends java.lang.Comparable<? super T>> reactor.core.publisher.Mono<T>	max(Publisher<T> source) Computes the maximum value of items in the source.
static <T> reactor.core.publisher.Mono<T>	max(Publisher<T> source, java.util.Comparator<? super T> comparator) Computes the maximum value of items in the source.
static <T extends java.lang.Comparable<? super T>> reactor.core.publisher.Mono<T>	min(Publisher<T> source) Computes the minimum value of items in the source.
static <T> reactor.core.publisher.Mono<T>	min(Publisher<T> source, java.util.Comparator<? super T> comparator) Computes the minimum value of items in the source.
static reactor.core.publisher.Mono<java.lang.Double>	sumDouble(Publisher<? extends java.lang.Number> source) Computes the double sum of items in the source.
static <T> reactor.core.publisher.Mono<java.lang.Double>	sumDouble(Publisher<T> source, java.util.function.Function<? super T,? extends java.lang.Number> mapping) Computes the double sum of items in the source, which are mapped to numerical values using the provided mapping.
static reactor.core.publisher.Mono<java.lang.Float>	sumFloat(Publisher<? extends java.lang.Number> source) Computes the float sum of items in the source.
static <T> reactor.core.publisher.Mono<java.lang.Float>	sumFloat(Publisher<T> source, java.util.function.Function<? super T,? extends java.lang.Number> mapping) Computes the float sum of items in the source, which are mapped to numerical values using the provided mapping.
static reactor.core.publisher.Mono<java.lang.Integer>	sumInt(Publisher<? extends java.lang.Number> source) Computes the integer sum of items in the source.
static <T> reactor.core.publisher.Mono<java.lang.Integer>	sumInt(Publisher<T> source, java.util.function.Function<? super T,? extends java.lang.Number> mapping) Computes the integer sum of items in the source, which are mapped to numerical values using the provided mapping.
static reactor.core.publisher.Mono<java.lang.Long>	sumLong(Publisher<? extends java.lang.Number> source) Computes the long sum of items in the source.
static <T> reactor.core.publisher.Mono<java.lang.Long>	sumLong(Publisher<T> source, java.util.function.Function<? super T,? extends java.lang.Number> mapping) Computes the long sum of items in the source, which are mapped to numerical values using the provided mapping.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MathFlux

public MathFlux()

Method Detail

sumInt

public static reactor.core.publisher.Mono<java.lang.Integer> sumInt(Publisher<? extends java.lang.Number> source)

Computes the integer sum of items in the source.

Parameters:

source - the numerical source

Returns:

Mono of the sum of items in source

sumInt

public static final <T> reactor.core.publisher.Mono<java.lang.Integer> sumInt(Publisher<T> source,
                                                                              java.util.function.Function<? super T,? extends java.lang.Number> mapping)

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

Parameters:

source - the source items

mapping - a function to map source items to numerical values

Returns:

Mono of the sum of items in source

sumLong

public static reactor.core.publisher.Mono<java.lang.Long> sumLong(Publisher<? extends java.lang.Number> source)

Computes the long sum of items in the source.

Parameters:

source - the numerical source

Returns:

Mono of the sum of items in source

sumLong

public static final <T> reactor.core.publisher.Mono<java.lang.Long> sumLong(Publisher<T> source,
                                                                            java.util.function.Function<? super T,? extends java.lang.Number> mapping)

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

Parameters:

source - the source items

mapping - a function to map source items to numerical values

Returns:

Mono of the sum of items in source

sumFloat

public static reactor.core.publisher.Mono<java.lang.Float> sumFloat(Publisher<? extends java.lang.Number> source)

Computes the float sum of items in the source.

Parameters:

source - the numerical source

Returns:

Mono of the sum of items in source

sumFloat

public static final <T> reactor.core.publisher.Mono<java.lang.Float> sumFloat(Publisher<T> source,
                                                                              java.util.function.Function<? super T,? extends java.lang.Number> mapping)

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

Parameters:

source - the source items

mapping - a function to map source items to numerical values

Returns:

Mono of the sum of items in source

sumDouble

public static reactor.core.publisher.Mono<java.lang.Double> sumDouble(Publisher<? extends java.lang.Number> source)

Computes the double sum of items in the source.

Parameters:

source - the numerical source

Returns:

Mono of the sum of items in source

sumDouble

public static final <T> reactor.core.publisher.Mono<java.lang.Double> sumDouble(Publisher<T> source,
                                                                                java.util.function.Function<? super T,? extends java.lang.Number> mapping)

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

Parameters:

source - the source items

mapping - a function to map source items to numerical values

Returns:

Mono of the sum of items in source

averageFloat

public static reactor.core.publisher.Mono<java.lang.Float> averageFloat(Publisher<? extends java.lang.Number> source)

Computes the float average of items in the source.

Parameters:

source - the numerical source

Returns:

Mono of the average of items in source

averageFloat

public static final <T> reactor.core.publisher.Mono<java.lang.Float> averageFloat(Publisher<T> source,
                                                                                  java.util.function.Function<? super T,? extends java.lang.Number> mapping)

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

Parameters:

source - the source items

mapping - a function to map source items to numerical values

Returns:

Mono of the average of items in source

averageDouble

public static reactor.core.publisher.Mono<java.lang.Double> averageDouble(Publisher<? extends java.lang.Number> source)

Computes the double average of items in the source.

Parameters:

source - the numerical source

Returns:

Mono of the average of items in source

averageDouble

public static final <T> reactor.core.publisher.Mono<java.lang.Double> averageDouble(Publisher<T> source,
                                                                                    java.util.function.Function<? super T,? extends java.lang.Number> mapping)

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

Parameters:

source - the source items

mapping - a function to map source items to numerical values

Returns:

Mono of the average of items in source

max

public static final <T extends java.lang.Comparable<? super T>> reactor.core.publisher.Mono<T> max(Publisher<T> source)

Computes the maximum value of items in the source.

Parameters:

source - the source containing comparable items

Returns:

Mono of the maximum value in source

max

public static <T> reactor.core.publisher.Mono<T> max(Publisher<T> source,
                                                     java.util.Comparator<? super T> comparator)

Computes the maximum value of items in the source.

Parameters:

source - the source containing items to compare

comparator - the comparator used to compare the items in source

Returns:

Mono of the maximum value in source

min

public static final <T extends java.lang.Comparable<? super T>> reactor.core.publisher.Mono<T> min(Publisher<T> source)

Computes the minimum value of items in the source.

Parameters:

source - the source containing comparable items

Returns:

Mono of the minimum value in source

min

public static <T> reactor.core.publisher.Mono<T> min(Publisher<T> source,
                                                     java.util.Comparator<? super T> comparator)

Computes the minimum value of items in the source.

Parameters:

source - the source containing items to compare

comparator - the comparator used to compare the items in source

Returns:

Mono of the minimum value in source