一、描述

按顺序对Observable发射的每项数据应用一个函数并发射最终的值。

Reduce操作符对原始Observable发射数据的第一项应用一个函数，然后再将这个函数的返回值与第二项数据一起传递给函数，以此类推，持续这个过程知道原始Observable发射它的最后一项数据并终止，此时Reduce返回的Observable发射这个函数返回的最终值。

在其它场景中，这种操作有时被称为累积，聚集，压缩，折叠，注射等。

注意如果原始Observable没有发射任何数据，reduce抛出异常IllegalArgumentException。

reduce默认不在任何特定的调度器上执行。

二、示意图

reduce

三、示例代码

Observable.just(1, 2, 3, 4)
    .reduce(new Func2<Integer, Integer, Integer>() {
        @Override
        public Integer call(Integer integer1, Integer integer2) {
            return integer1 + integer2;
        }
    })
    .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);
        }
    });