python - 在 RxPy 中使用 first()

Question

如何从ObservableRxPy 中的序列中恢复元素

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