RxPY 实用操作符
delay
这个操作符将根据给定的时间或日期延迟源可观察对象的发射。
语法
参数
timespan:这将是以秒为单位或日期的时间。
返回值
它将返回一个可观察的对象,其中包含超时后发出的源值。
示例
输出
materialize
这个操作符将会将源Observable中的值转换成显式通知值的形式进行发出。
语法
返回值
这将返回一个可观测对象,以明确的通知值形式发出的值。
示例
输出
time_interval
此运算符将给出源可观察对象中的值之间经过的时间。
语法
返回值
它将返回一个可观察对象,其中包含源值发出之间经过的时间。
示例
输出
timeout
这个操作符会在经过指定时间后从源可观察对象中发出所有的值,否则会触发一个错误。
语法
参数
duetime: 给定的时间,以秒为单位。
返回值
它将返回一个可观察对象,其中包含来自源可观察对象的所有值。
示例
输出
timestamp
此操作符会将来自源可观察对象的所有值都附加上时间戳。
语法
返回值
它将返回一个包含源可观察对象中所有值及其时间戳的可观察对象。
示例
输出
E:\pyrx>python testrx.py
The value is Timestamp(value=1, timestamp=datetime.datetime(2019, 11, 4, 4, 57,
44, 667243))
The value is Timestamp(value=2, timestamp=datetime.datetime(2019, 11, 4, 4, 57,
44, 668243))
The value is Timestamp(value=3, timestamp=datetime.datetime(2019, 11, 4, 4, 57,
44, 668243))
The value is Timestamp(value=4, timestamp=datetime.datetime(2019, 11, 4, 4, 57,
44, 668243))
The value is Timestamp(value=5, timestamp=datetime.datetime(2019, 11, 4, 4, 57,
44, 669243))
The value is Timestamp(value=6, timestamp=datetime.datetime(2019, 11, 4, 4, 57,
44, 669243))