Package hu.akarnokd.rxjava3.math
Class MathFlowable
- java.lang.Object
-
- hu.akarnokd.rxjava3.math.MathFlowable
-
public final class MathFlowable extends java.lang.ObjectUtility 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<java.lang.Double>averageDouble(Publisher<? extends java.lang.Number> source)static Flowable<java.lang.Float>averageFloat(Publisher<? extends java.lang.Number> source)static <T extends java.lang.Comparable<? super T>>
Flowable<T>max(Publisher<T> source)static <T> Flowable<T>max(Publisher<T> source, java.util.Comparator<? super T> comparator)static <T extends java.lang.Comparable<? super T>>
Flowable<T>min(Publisher<T> source)static <T> Flowable<T>min(Publisher<T> source, java.util.Comparator<? super T> comparator)static Flowable<java.lang.Double>sumDouble(Publisher<java.lang.Double> source)static Flowable<java.lang.Float>sumFloat(Publisher<java.lang.Float> source)static Flowable<java.lang.Integer>sumInt(Publisher<java.lang.Integer> source)static Flowable<java.lang.Long>sumLong(Publisher<java.lang.Long> source)
-
-
-
Method Detail
-
max
public static <T> Flowable<T> max(Publisher<T> source, java.util.Comparator<? super T> comparator)
-
min
public static <T> Flowable<T> min(Publisher<T> source, java.util.Comparator<? super T> comparator)
-
averageFloat
public static Flowable<java.lang.Float> averageFloat(Publisher<? extends java.lang.Number> source)
-
-