Class MathFlowable


  • public final class MathFlowable
    extends java.lang.Object
    Utility methods to work with numerical Flowable sources: sum, min, max and average.
    • Method Detail

      • sumInt

        public static Flowable<java.lang.Integer> sumInt​(Publisher<java.lang.Integer> source)
      • sumLong

        public static Flowable<java.lang.Long> sumLong​(Publisher<java.lang.Long> source)
      • sumFloat

        public static Flowable<java.lang.Float> sumFloat​(Publisher<java.lang.Float> source)
      • sumDouble

        public static Flowable<java.lang.Double> sumDouble​(Publisher<java.lang.Double> source)
      • max

        public static <T extends java.lang.Comparable<? super T>> Flowable<T> max​(Publisher<T> source)
      • max

        public static <T> Flowable<T> max​(Publisher<T> source,
                                          java.util.Comparator<? super T> comparator)
      • min

        public static <T extends java.lang.Comparable<? super T>> Flowable<T> min​(Publisher<T> source)
      • 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)
      • averageDouble

        public static Flowable<java.lang.Double> averageDouble​(Publisher<? extends java.lang.Number> source)