-
Notifications
You must be signed in to change notification settings - Fork 616
Mathematical and Aggregate Operators
mcxiaoke edited this page Jul 19, 2015
·
34 revisions
本页展示的操作符用于对整个序列执行算法操作或其它操作,由于这些操作必须等待数据发送完成(通常也必须缓存这些数据),它们对于非常长或者无限的序列来说是危险的,不推荐使用。
-
averageInteger( )
— 求序列平均数并发送 -
averageLong( )
— 求序列平均数并发送 -
averageFloat( )
— 求序列平均数并发送 -
averageDouble( )
— 求序列平均数并发送 -
max( )
— 求序列最大值并发送 -
maxBy( )
— 求最大key对应的值并发送 -
min( )
— 求最小值并发送 -
minBy( )
— 求最小Key对应的值并发送 -
sumInteger( )
— 求和并发送 -
sumLong( )
— 求和并发送 -
sumFloat( )
— 求和并发送 -
sumDouble( )
— 求和并发送
-
concat( )
— 顺序连接多个Observables -
count( )
andcountLong( )
— 计算数据项的个数并发送结果 -
reduce( )
— 对序列使用reduce()函数并发送对吼的结果 -
collect( )
— 将原Observable发送的数据放到一个单一的可变的数据结构中,然后返回一个发送这个数据结构的Observable -
toList( )
— 收集原Observable发送的所有数据到一个列表,然后返回这个列表 -
toSortedList( )
— 收集原Observable发送的所有数据到一个有序列表,然后返回这个列表 -
toMap( )
— 将序列数据转换为一个Map,Map的key是根据一个函数计算的 -
toMultiMap( )
— 将序列数据转换为一个列表,同时也是一个Map,Map的key是根据一个函数计算的