反应式编程存储结果为变量

reactive programming store result in a variable

快速(琐碎)问题:我找不到一种方法来将对可观察对象的一系列操作的输出存储在外部变量中。 例如:

mylist = []
Observable.from_([1, 2, 3]).to_list().store(mylist)

不确定这很"reactive",但应该是微不足道的。

提前致谢

C

这是我找到的解决方案:

mylist = []

def store(value):
    mylist.append(value)

Observable.from_([1, 2, 3]).do_action(store).subscribe()

print(mylist)

评论?

谢谢

通过 .to_blocking() 将您的可观察对象变成阻塞对象。现在您可以对其进行迭代。

mylist=list(Observable.from_([1, 2, 3]).to_blocking())                                                                   

print(mylist)