RxPY 数学运算符
average
此运算符将计算给定源可观测对象的平均值,并输出一个具有平均值的可观测对象。
语法
返回值
返回一个可观察对象,其值为平均值。
示例
输出
concat
此操作符将接收两个或多个Observables,并生成一个包含所有值的Observable序列。
语法
参数
Observables:要连接的可观察对象的列表。
返回值
返回一个可观察对象,该对象包含源可观察对象的值合并的单个值。
示例
testrx.py
输出
count
该操作符接收带有值的可观测对象,并将其转换为只有一个值的可观测对象。count函数接收一个可选的谓词函数作为参数。该函数的类型为布尔型,并且只有在满足条件时才会将值添加到输出中。
语法
参数
count函数将谓词函数作为可选参数传入。该函数的类型为布尔型,只有满足条件时才会将值添加到输出中。
返回值
它将返回一个包含单个值的可观察对象,即源可观察对象的计数值。
示例 1
输出
示例2:使用谓词函数
输出
max
这个运算符将从源 observable 中给出具有最大值的 observable。
语法
参数
comparer_function:可选参数。这个函数用于比较源可观察对象的值。
返回值
它返回一个带有源可观察对象中最大值的可观察对象。
示例1
输出
示例2:comparer_function
输出
min
此操作符将从源可观察对象中返回具有最小值的可观察对象。
语法
参数
comparer_function:可选参数,此函数用于比较源可观察对象的值。
返回值
它返回一个具有源可观察对象中最小值的可观察对象。
示例1
输出
示例2:使用comparer_function
输出
reduce
语法
参数
accumulator_func: 一个函数,用于对来自源 observable 的值进行处理,并返回一个 observale 形式的累加值。
seed: 可选的。默认值未被设置。它是初始值,用于在累加函数内部使用。
返回值
返回一个 observable,每个源 observable 的值都会通过累加函数进行处理,返回一个单个值作为输出。
示例
输出
sum
此操作符将返回一个包含源可观察对象中所有值的总和的可观察对象。
语法
参数
key_mapper:可选。这是一个函数,应用于来自源可观测对象的值。
返回值
返回一个可观测对象,其中包含源可观测对象中所有值的总和。
示例1
输出
示例2:使用key_mapper函数
通过key_mapper函数,我们将所有的值增加1,并将它们求和。