python - 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() 转换允许访问内部值。