RxPY - 转换运算符
-
简述
-
缓冲
该操作符将从可观察源收集所有值,并在满足给定边界条件后定期发出它们。句法
参数
boundaries:输入是可观察的,它将决定何时停止,以便发出收集的值。返回值
返回值是可观察的,它将具有从源可观察对象收集的所有值,即持续时间由所采用的输入可观察对象决定。例子
输出
-
ground_by
该运算符将根据给定的 key_mapper 函数对来自源 observable 的值进行分组。句法
参数
key_mapper:这个函数将负责从源 observable 中提取键。返回值
它返回一个 observable,其值基于 key_mapper 函数分组。例子
输出
-
map
该运算符将根据给定的 mapper_func 的输出将源 observable 中的每个值更改为新值。句法
参数
mapper_func:(可选)它将根据来自此函数的输出更改源 observable 的值。例子
输出
-
scan
该运算符将对来自源 observable 的值应用一个累加器函数,并返回一个带有新值的 observable。句法
参数
accumulator_func:此函数应用于源 observable 中的所有值。seed:(可选)在 accumular_func 中使用的初始值。返回值
该运算符将返回一个可观察对象,该可观察对象将基于应用于源可观察对象的每个值的累加器函数具有新值。例子
输出