Как заставить python реактивный подписываться постоянно

Я пытаюсь сделать заметную реакцию на дополнение к списку, но я не могу этого сделать. Он не реагирует, пока я не позвоню подписаться:

>>> from rx import Observer
>>> alist= [1,2,3]
>>> source = Observable.from_list(alist)
>>> source.subscribe(lambda value: print(f'got {value}!'))
got 1!
got 2!
got 3!
>>> alist.append('hi')
>>> source.subscribe(lambda value: print(f'got {value}!'))
got 1!
got 2!
got 3!
got hi!

Как я могу заставить это сделать действие, такое как печать got hi! когда 'hi' добавлен в список?

0 ответов

Другие вопросы по тегам