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