Я получаю сообщение об ошибке «AttributeError: тип объекта« Наблюдаемый »не имеет атрибута« from_ »» в python rx = 3.0.1

Question

это код из книги «Реактивное программирование с python», которую я попробовал на своем ноутбуке.

import sys
from rx import Observable

argv = Observable.from_(sys.argv[1:])
argv.subscribe(
    on_next=lambda i: print("on_next: {}".format(i)),
    on_error=lambda e: print("on_error: {}".format(e)),
    on_completed=lambda: print("on_completed")
)

Если я запустил

python echo1.py hello world there

, вывод должен выглядеть следующим образом:

on_next: hello 
on_next: world 
on_next: there 
on_completed

Answer 1

Я полагаю, что проблема заключается в импорте, так как импорт RxPY 3.0.1, похоже, работает по-другому, теперь вы импортируете from_ напрямую из rx.

Возможно, вы захотите взглянуть на Начало работы и разделы Миграция в документах RxPY, которые они должны объяснить гораздо лучше, чем я, как это теперь работает.

import sys
from rx import from_

argv = ops.from_(sys.argv[1:])
argv.subscribe(
    on_next=lambda i: print("on_next: {}".format(i)),
    on_error=lambda e: print("on_error: {}".format(e)),
    on_completed=lambda: print("on_completed")
)