RxPY – utility操作符
delay
该操作符将按照给定的时间或日期延迟源观测排放。
语法
参数
timespan:这将是以秒为单位的时间或日期。
返回值
它将返回一个带有超时后发出的源值的可观察变量。
例子
输出
materialize
这个操作符将把来自源观测器的值与以显式通知值的形式发出的值进行转换。
语法
返回值
这将返回一个可观察到的、以显式通知值形式发射的值。
例子
输出
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))