在 RxPy 中使用 first()

Question

如何从 RxPy

中的 Observable 序列恢复元素

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

应该打印 1，但它 returns 另一个 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() 转换允许访问内部值。