RxJava2操作符

RxJava2操作符之“Scan”

2017-04-01  本文已影响55人  坑吭吭

作用

扫描,遍历,用法和上一个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;
结束

总结

这个系列只有干货,如果大家有什么好的建议的话欢迎在下面评论。或者觉得我哪里写的不够形象了,同样可以提出来。

上一篇 下一篇

猜你喜欢

热点阅读