RxPY 转换操作符
buffer
此操作符将从源可观察对象中收集所有值,并在满足给定的边界条件后以固定间隔发出它们。
语法
参数
boundaries:输入是一个可观察对象,决定何时停止以便发出已收集的值。
返回值
返回值是一个可观察对象,其中包含根据输入可观察对象的时间段从源可观察对象中收集的所有值。
示例
输出
ground_by
这个操作符将根据给定的key_mapper函数,对来自源Observable的值进行分组。
语法
参数
key_mapper:这个函数将负责从源observable中提取键。
返回值
它返回一个根据key_mapper函数进行分组的observable。
示例
输出
map
这个操作符将根据给定的mapper_func函数的输出,将源Observable的每个值转换为一个新的值。
语法
参数
mapper_func:(可选)它将根据从此函数传出的值更改源可观察对象的值。
示例
输出
scan
这个操作符将一个累加函数应用于来自源可观察对象的值,并返回一个带有新值的可观察对象。
语法
参数
accumulator_func:将此函数应用于源可观察对象的所有值。
seed:(可选)在accumulator_func内部使用的初始值。
返回值
此操作符将返回一个可观察对象,该对象的新值将基于对源可观察对象的每个值应用的累加器函数。