Package hu.akarnokd.rxjava3.math
Class MathFlowable
- java.lang.Object
-
- hu.akarnokd.rxjava3.math.MathFlowable
-
public final class MathFlowable extends Object
Utility methods to work with numerical Flowable sources: sum, min, max and average.
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static Flowable<Double>averageDouble(Publisher<? extends Number> source)static Flowable<Float>averageFloat(Publisher<? extends Number> source)static <T extends Comparable<? super T>>
Flowable<T>max(Publisher<T> source)static <T> Flowable<T>max(Publisher<T> source, Comparator<? super T> comparator)static <T extends Comparable<? super T>>
Flowable<T>min(Publisher<T> source)static <T> Flowable<T>min(Publisher<T> source, Comparator<? super T> comparator)static Flowable<Double>sumDouble(Publisher<Double> source)static Flowable<Float>sumFloat(Publisher<Float> source)static Flowable<Integer>sumInt(Publisher<Integer> source)static Flowable<Long>sumLong(Publisher<Long> source)
-
-
-
Method Detail
-
max
public static <T extends Comparable<? super T>> Flowable<T> max(Publisher<T> source)
-
max
public static <T> Flowable<T> max(Publisher<T> source, Comparator<? super T> comparator)
-
min
public static <T extends Comparable<? super T>> Flowable<T> min(Publisher<T> source)
-
min
public static <T> Flowable<T> min(Publisher<T> source, Comparator<? super T> comparator)
-
-