一、描述

计算原始Observable发射数字的平均值并发射它。

Average操作符操作符一个发射数字的Observable，并发射单个值：原始Observable发射的数字序列的平均值。

这个操作符不包含在RxJava核心模块中，它属于不同的rxjava-math模块。它被实现为四个操作符：averageDouble, averageFloat, averageInteger, averageLong。

如果原始Observable不发射任何数据，这个操作符会抛异常：IllegalArgumentException。

二、示意图

average

三、示例代码

由于average操作符是属于可选的rxjava-math模块的，所以需要加入下面的依赖：

1	compile 'io.reactivex:rxjava-math:1.0.0'

MathObservable.averageInteger(Observable.just(1, 2, 3, 4))
    .subscribe(new Subscriber<Integer>() {
        @Override
        public void onCompleted() {
            System.out.println("onCompleted.");
        }

        @Override
        public void onError(Throwable e) {
            System.out.println("onError: " + e.getMessage());
        }

        @Override
        public void onNext(Integer integer) {
            System.out.println("onNext: " + integer);
        }
    });