diff --git a/src/main/java/rx/observables/MathObservable.java b/src/main/java/rx/observables/MathObservable.java index 1514f1c..2ffa0c9 100644 --- a/src/main/java/rx/observables/MathObservable.java +++ b/src/main/java/rx/observables/MathObservable.java @@ -42,7 +42,7 @@ public static MathObservable from(Observable o) { /** * Returns an Observable that emits the average of the Doubles emitted by the source Observable. *

- * + * * * @param source * source Observable to compute the average of @@ -58,7 +58,7 @@ public final static Observable averageDouble(Observable source) /** * Returns an Observable that emits the average of the Floats emitted by the source Observable. *

- * + * * * @param source * source Observable to compute the average of @@ -74,7 +74,7 @@ public final static Observable averageFloat(Observable source) { /** * Returns an Observable that emits the average of the Integers emitted by the source Observable. *

- * + * * * @param source * source Observable to compute the average of @@ -92,7 +92,7 @@ public final static Observable averageInteger(Observable sourc /** * Returns an Observable that emits the average of the Longs emitted by the source Observable. *

- * + * * * @param source * source Observable to compute the average of @@ -110,7 +110,7 @@ public final static Observable averageLong(Observable source) { * numeric value. If there is more than one item with the same maximum value, it emits the last-emitted of * these. *

- * + * * * @param source * an Observable to scan for the maximum emitted item @@ -128,7 +128,7 @@ public final static > Observable max(Observab * Returns an Observable that emits the single numerically minimum item emitted by the source Observable. * If there is more than one such item, it returns the last-emitted one. *

- * + * * * @param source * an Observable to determine the minimum item of @@ -144,7 +144,7 @@ public final static > Observable min(Observab /** * Returns an Observable that emits the sum of all the Doubles emitted by the source Observable. *

- * + * * * @param source * the source Observable to compute the sum of @@ -160,7 +160,7 @@ public final static Observable sumDouble(Observable source) { /** * Returns an Observable that emits the sum of all the Floats emitted by the source Observable. *

- * + * * * @param source * the source Observable to compute the sum of @@ -176,7 +176,7 @@ public final static Observable sumFloat(Observable source) { /** * Returns an Observable that emits the sum of all the Integers emitted by the source Observable. *

- * + * * * @param source * source Observable to compute the sum of @@ -192,7 +192,7 @@ public final static Observable sumInteger(Observable source) { /** * Returns an Observable that emits the sum of all the Longs emitted by the source Observable. *

- * + * * * @param source * source Observable to compute the sum of @@ -209,7 +209,7 @@ public final static Observable sumLong(Observable source) { * Returns an Observable that transforms items emitted by the source Observable into Doubles by using a * function you provide and then emits the Double average of the complete sequence of transformed values. *

- * + * * * @param valueExtractor * the function to transform an item emitted by the source Observable into a Double @@ -226,7 +226,7 @@ public final Observable averageDouble(Func1 valueExtr * Returns an Observable that transforms items emitted by the source Observable into Floats by using a * function you provide and then emits the Float average of the complete sequence of transformed values. *

- * + * * * @param valueExtractor * the function to transform an item emitted by the source Observable into a Float @@ -243,7 +243,7 @@ public final Observable averageFloat(Func1 valueExtract * Returns an Observable that transforms items emitted by the source Observable into Integers by using a * function you provide and then emits the Integer average of the complete sequence of transformed values. *

- * + * * * @param valueExtractor * the function to transform an item emitted by the source Observable into an Integer @@ -260,7 +260,7 @@ public final Observable averageInteger(Func1 valueE * Returns an Observable that transforms items emitted by the source Observable into Longs by using a * function you provide and then emits the Long average of the complete sequence of transformed values. *

- * + * * * @param valueExtractor * the function to transform an item emitted by the source Observable into a Long @@ -278,7 +278,7 @@ public final Observable averageLong(Func1 valueExtractor) * specified comparator. If there is more than one item with the same maximum value, it emits the * last-emitted of these. *

- * + * * * @param comparator * the comparer used to compare items @@ -297,7 +297,7 @@ public final Observable max(Comparator comparator) { * Returns an Observable that emits the minimum item emitted by the source Observable, according to a * specified comparator. If there is more than one such item, it returns the last-emitted one. *

- * + * * * @param comparator * the comparer used to compare elements @@ -316,7 +316,7 @@ public final Observable min(Comparator comparator) { * Returns an Observable that extracts a Double from each of the items emitted by the source Observable via * a function you specify, and then emits the sum of these Doubles. *

- * + * * * @param valueExtractor * the function to extract a Double from each item emitted by the source Observable @@ -333,7 +333,7 @@ public final Observable sumDouble(Func1 valueExtracto * Returns an Observable that extracts a Float from each of the items emitted by the source Observable via * a function you specify, and then emits the sum of these Floats. *

- * + * * * @param valueExtractor * the function to extract a Float from each item emitted by the source Observable @@ -350,7 +350,7 @@ public final Observable sumFloat(Func1 valueExtractor) * Returns an Observable that extracts an Integer from each of the items emitted by the source Observable * via a function you specify, and then emits the sum of these Integers. *

- * + * * * @param valueExtractor * the function to extract an Integer from each item emitted by the source Observable @@ -367,7 +367,7 @@ public final Observable sumInteger(Func1 valueExtra * Returns an Observable that extracts a Long from each of the items emitted by the source Observable via a * function you specify, and then emits the sum of these Longs. *

- * + * * * @param valueExtractor * the function to extract a Long from each item emitted by the source Observable