RxJava操作符实践:8_算术和聚合操作之3_min

Posted lijianming180

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了RxJava操作符实践:8_算术和聚合操作之3_min相关的知识,希望对你有一定的参考价值。

发射原始Observable的最小值。

Min操作符操作一个发射数值的Observable并发射单个值:最小的那个值。

RxJava中,min属于rxjava-math模块。

min接受一个可选参数,用于比较两项数据的大小,如果最小值的数据超过一项,min会发射原始Observable最近发射的那一项。

minBy类似于min,但是它发射的不是最小值,而是发射Key最小的项,Key由你指定的一个函数生成。

二、示意图

技术图片

三、示例代码

由于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.min(Observable.just(10, 6, 23, 9))
.subscribe(new Subscriber<Integer>() {

public void ()大专栏  RxJava操作符实践:8_算术和聚合操作之3_minn> {
System.out.println("onCompleted.");
}


public void onError(Throwable e) {
System.out.println("onError: " + e.getMessage());
}


public void onNext(Integer integer) {
System.out.println("onNext: " + integer);
}
});

四、运行结果

1
2
onNext: 6
onCompleted.

五、更多

跟min相关的操作符还有:

  • minBy

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

六、参考资料

ReactiveX官方文档

ReactiveX文档中文翻译

PS:欢迎关注 SherlockShi 个人博客

以上是关于RxJava操作符实践:8_算术和聚合操作之3_min的主要内容,如果未能解决你的问题,请参考以下文章

Update:sparksql:第3节 Dataset (DataFrame) 的基础操作 & 第4节 SparkSQL_聚合操作_连接操作

Rxjava源码分析&实践实践环节:map操作符功能实现

欢迎进入Hensen_的博客目录(全站式导航)

RxJava操作符 __结合操作

算法_计算输入的算术表达式的值.

SecureCrt配置之自动存储操作日志