Я полагаю, что проблема заключается в импорте, так как импорт 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")
)