RxJava操作符实践:8_算术和聚合操作之4_sum

一、描述

计算Observable发射的数值的和并发射这个和。

Sum操作符操作一个发射数值的Observable,仅发射单个值:原始Observable所有数值的和。

RxJava的实现是sumDouble, sumFloat, sumInteger, sumLong,它们不是RxJava核心模块的一部分,属于rxjava-math模块。

二、示意图

sum

三、示例代码

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

1
compile 'io.reactivex:rxjava-math:1.0.0'
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
MathObservable.sumInteger(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);
}
});

四、运行结果

1
2
onNext: 10
onCompleted.

五、更多

跟sum相关的操作符还有:

  • stringConcat
  • join

详情可查阅下面的参考资料。

六、参考资料

ReactiveX官方文档

ReactiveX文档中文翻译

PS:欢迎关注 SherlockShi 个人博客

感谢你的支持,让我继续努力分享有用的技术和知识点!