com.github.kongpf8848.rx.observables

类 MathObservable<T>

java.lang.Object

com.github.kongpf8848.rx.observables.MathObservable<T>

public class MathObservable<T>
extends java.lang.Object

方法概要

限定符和类型	方法和说明
io.reactivex.Observable<java.lang.Double>	averageDouble(io.reactivex.functions.Function<? super T,java.lang.Double> valueExtractor)
static io.reactivex.Observable<java.lang.Double>	averageDouble(io.reactivex.Observable<java.lang.Double> source)
io.reactivex.Observable<java.lang.Float>	averageFloat(io.reactivex.functions.Function<? super T,java.lang.Float> valueExtractor)
static io.reactivex.Observable<java.lang.Float>	averageFloat(io.reactivex.Observable<java.lang.Float> source)
io.reactivex.Observable<java.lang.Integer>	averageInteger(io.reactivex.functions.Function<? super T,java.lang.Integer> valueExtractor)
static io.reactivex.Observable<java.lang.Integer>	averageInteger(io.reactivex.Observable<java.lang.Integer> source)
io.reactivex.Observable<java.lang.Long>	averageLong(io.reactivex.functions.Function<? super T,java.lang.Long> valueExtractor)
static io.reactivex.Observable<java.lang.Long>	averageLong(io.reactivex.Observable<java.lang.Long> source)
static <T> MathObservable<T>	from(io.reactivex.Observable<T> o)
io.reactivex.Observable<T>	max(java.util.Comparator<? super T> comparator)
static <T extends java.lang.Comparable<? super T>> io.reactivex.Observable<T>	max(io.reactivex.Observable<T> source)
io.reactivex.Observable<T>	min(java.util.Comparator<? super T> comparator)
static <T extends java.lang.Comparable<? super T>> io.reactivex.Observable<T>	min(io.reactivex.Observable<T> source)
io.reactivex.Observable<java.lang.Double>	sumDouble(io.reactivex.functions.Function<? super T,java.lang.Double> valueExtractor)
static io.reactivex.Observable<java.lang.Double>	sumDouble(io.reactivex.Observable<java.lang.Double> source)
io.reactivex.Observable<java.lang.Float>	sumFloat(io.reactivex.functions.Function<? super T,java.lang.Float> valueExtractor)
static io.reactivex.Observable<java.lang.Float>	sumFloat(io.reactivex.Observable<java.lang.Float> source)
io.reactivex.Observable<java.lang.Integer>	sumInteger(io.reactivex.functions.Function<? super T,java.lang.Integer> valueExtractor)
static io.reactivex.Observable<java.lang.Integer>	sumInteger(io.reactivex.Observable<java.lang.Integer> source)
io.reactivex.Observable<java.lang.Long>	sumLong(io.reactivex.functions.Function<? super T,java.lang.Long> valueExtractor)
static io.reactivex.Observable<java.lang.Long>	sumLong(io.reactivex.Observable<java.lang.Long> source)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

方法详细资料

from

public static <T> MathObservable<T> from(io.reactivex.Observable<T> o)

averageDouble

public static final io.reactivex.Observable<java.lang.Double> averageDouble(io.reactivex.Observable<java.lang.Double> source)

averageFloat

public static final io.reactivex.Observable<java.lang.Float> averageFloat(io.reactivex.Observable<java.lang.Float> source)

averageInteger

public static final io.reactivex.Observable<java.lang.Integer> averageInteger(io.reactivex.Observable<java.lang.Integer> source)

averageLong

public static final io.reactivex.Observable<java.lang.Long> averageLong(io.reactivex.Observable<java.lang.Long> source)

max

public static final <T extends java.lang.Comparable<? super T>> io.reactivex.Observable<T> max(io.reactivex.Observable<T> source)

min

public static final <T extends java.lang.Comparable<? super T>> io.reactivex.Observable<T> min(io.reactivex.Observable<T> source)

sumDouble

public static final io.reactivex.Observable<java.lang.Double> sumDouble(io.reactivex.Observable<java.lang.Double> source)

sumFloat

public static final io.reactivex.Observable<java.lang.Float> sumFloat(io.reactivex.Observable<java.lang.Float> source)

sumInteger

public static final io.reactivex.Observable<java.lang.Integer> sumInteger(io.reactivex.Observable<java.lang.Integer> source)

sumLong

public static final io.reactivex.Observable<java.lang.Long> sumLong(io.reactivex.Observable<java.lang.Long> source)

averageDouble

public final io.reactivex.Observable<java.lang.Double> averageDouble(io.reactivex.functions.Function<? super T,java.lang.Double> valueExtractor)

averageFloat

public final io.reactivex.Observable<java.lang.Float> averageFloat(io.reactivex.functions.Function<? super T,java.lang.Float> valueExtractor)

averageInteger

public final io.reactivex.Observable<java.lang.Integer> averageInteger(io.reactivex.functions.Function<? super T,java.lang.Integer> valueExtractor)

averageLong

public final io.reactivex.Observable<java.lang.Long> averageLong(io.reactivex.functions.Function<? super T,java.lang.Long> valueExtractor)

max

public final io.reactivex.Observable<T> max(java.util.Comparator<? super T> comparator)

min

public final io.reactivex.Observable<T> min(java.util.Comparator<? super T> comparator)

sumDouble

public final io.reactivex.Observable<java.lang.Double> sumDouble(io.reactivex.functions.Function<? super T,java.lang.Double> valueExtractor)

sumFloat

public final io.reactivex.Observable<java.lang.Float> sumFloat(io.reactivex.functions.Function<? super T,java.lang.Float> valueExtractor)

sumInteger

public final io.reactivex.Observable<java.lang.Integer> sumInteger(io.reactivex.functions.Function<? super T,java.lang.Integer> valueExtractor)

sumLong

public final io.reactivex.Observable<java.lang.Long> sumLong(io.reactivex.functions.Function<? super T,java.lang.Long> valueExtractor)