RxPY - 合并运算符
combine_latest
此运算符将为作为输入提供的可观察对象创建一个元组。
语法
combine_latest(observable1,observable2,.....)
参数
Observable：可观察对象。
返回值
它返回值，其中源可观察对象中的值已转换为元组。
示例
from rx import of, operators as op
from datetime import date
test = of(1,2,3,4,5,6)
test2 = of(11,12,13,14,15,16)
test3 = of(111,112,113,114,115,116)
sub1 = test.pipe(
op.combine_latest(test2, test3)
)
sub1.subscribe(lambda x: print("The value is {0}".format(x)))
输出
E:\pyrx>python testrx.py The value is (6, 16, 111) The value is (6, 16, 112) The value is (6, 16, 113) The value is (6, 16, 114) The value is (6, 16, 115) The value is (6, 16, 116)
merge
此运算符将合并给定的可观察对象。
语法
merge(observable)
参数
Observable：可观察对象。
返回值
它将返回值，其中来自给定的可观察对象的一个序列。
示例
from rx import of, operators as op
from datetime import date
test = of(1,2,3,4,5,6)
test2 = of(11,12,13,14,15,16)
sub1 = test.pipe(
op.merge(test2)
)
sub1.subscribe(lambda x: print("The value is {0}".format(x)))
输出
E:\pyrx>python testrx.py The value is 1 The value is 2 The value is 3 The value is 4 The value is 5 The value is 6 The value is 11 The value is 12 The value is 13 The value is 14 The value is 15 The value is 16
start_with
此运算符将采用给定的值，并将其添加到源可观察对象返回的完整序列的开头。
语法
start_with(values)
参数
values：您希望在开头添加的前缀值。
返回值
它返回值，其中给定的值以开头前缀形式添加，后面紧跟源可观察对象中的值。
示例
from rx import of, operators as op
from datetime import date
test = of(1,2,3,4,5,6)
sub1 = test.pipe(
op.start_with(-2,-1,0)
)
sub1.subscribe(lambda x: print("The value is {0}".format(x)))xExample
输出
E:\pyrx>python testrx.py The value is -2 The value is -1 The value is 0 The value is 1 The value is 2 The value is 3 The value is 4 The value is 5 The value is 6
zip
此运算符返回值，其中值为元组形式，该形式通过获取给定可观察对象的第一个值等来形成。
语法
zip(observable1, observable2...)
参数
Observable：可观察对象
返回值
它返回值，其中值为元组格式。
示例
from rx import of, operators as op
from datetime import date
test = of(1,2,3,4,5,6)
test1 = of(4,8,12,16,20)
test2 = of(5,10,15,20,25)
sub1 = test.pipe(
op.zip(test1, test2)
)
sub1.subscribe(lambda x: print("The value is {0}".format(x)))
输出
E:\pyrx>python testrx.py The value is (1, 4, 5) The value is (2, 8, 10) The value is (3, 12, 15) The value is (4, 16, 20) The value is (5, 20, 25)
广告