作用
扫描,遍历,用法和上一个Reduce
操作符差不多,只是这个操作符会将每一个过程的中间产物发射出来,而不是只发射结果
示例用法
这里举个例子,做一下累加计算
Observable.just(1, 2, 3, 4,5)//创建了一个有5个数字的被观察者
.scan(new BiFunction<Integer, Integer, Integer>() {
@Override
public Integer apply(Integer t1, Integer t2) {
return t1 + t2;//累加操作,如果是-就是累减操作。。依此类推
}
})
.subscribe(getObserver())//这里的观察者依然不重要
这里前两个数计算的结果会作为第二个计算的t1
传进来,直到处理完最后一次计算
运行结果
1,3,6,10,15
分析
我们的被观察者中有5个数,分别是1,2,3,4,5
scan的过程:
第一个参数1不够两个,直接发射结果1;
之后:
t1 = 1;t2 = 2
计算:t1 + t2 = 3,发射结果3;
t1 = 3;t2 = 3;
计算: t1 + t2 = 6,发射结果6;
t1 = 6;t2 = 4;
计算 :t1 + t2 = 10,发射结果10;
t1 = 10;t2 = 5;
计算 :t1 + t2 = 15,发射结果15;
结束
总结
这个系列只有干货,如果大家有什么好的建议的话欢迎在下面评论。或者觉得我哪里写的不够形象了,同样可以提出来。