Я пытаюсь заметным образом отреагировать на добавление в список, но я не могу этого сделать.Он не реагирует до тех пор, пока я не позвоню по подписке:
>>> 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!
Как мне заставить его выполнить действие, такое как print got hi!, когда 'hi' добавлено в список?