RxPy中first（）的用法

Question

如何从RxPy中的Observable序列中恢复元素

obs = Observable.from_([1,2,3])
print obs.first()

应该打印1，但它返回另一个AnonymousObservable，而不是元素。在

一般来说，从Observable序列中恢复元素的最佳运算符是什么？在

Answer 1

这对我有用

obs = Observable.from_([1,2,3])
first = list(obs.first().to_blocking())[0]
print(first)

to_blocking调用将序列转换为迭代器（类型为rx.core.blockingobservable公司.BlockingObservable），以及list() 转换允许访问内部值。在