Scan

连续地对数据序列的每一项应用一个函数，然后连续发射结果

scan

Scan操作符对原始Observable发射的第一项数据应用一个函数，然后将那个函数的结果作为自己的第一项数据发射。它将函数的结果同第二项数据一起填充给这个函数来产生它自己的第二项数据。它持续进行这个过程来产生剩余的数据序列。这个操作符在某些情况下被叫做accumulator。

scan

RxJava实现了scan操作符。

示例代码：

  2. Observable.just(1, 2, 3, 4, 5)
  3.     .scan(new Func2<Integer, Integer, Integer>() {
  4.         @Override
  5.         public Integer call(Integer sum, Integer item) {
  6.             return sum + item;
  7.         }
  8.     }).subscribe(new Subscriber<Integer>() {
  9.         @Override
  10.         public void onNext(Integer item) {
  11.             System.out.println("Next: " + item);
  12.         }
  14.         @Override
  15.         public void onError(Throwable error) {
  16.             System.err.println("Error: " + error.getMessage());
  17.         }
  19.         @Override
  20.         public void onCompleted() {
  21.             System.out.println("Sequence complete.");
  22.         }
  23.     });

输出

  1. Next: 1
  2. Next: 3
  3. Next: 6
  4. Next: 10
  5. Next: 15
  6. Sequence complete.

scanSeed

有一个scan操作符的变体，你可以传递一个种子值给累加器函数的第一次调用（Observable发射的第一项数据）。如果你使用这个版本，scan将发射种子值作为自己的第一项数据。注意：传递null作为种子值与不传递是不同的，null种子值是合法的。

这个操作符默认不在任何特定的调度器上执行。