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