Тип объекта «ObservableBase» не имеет атрибута «создать» RxPy

Question

Я пытаюсь понять, как работает RxPy, я получаю эту ошибку

объект типа 'ObservableBase' не имеет атрибута 'create'

Я использую python3.6 и мой код

from rx import Observable

stocks = [
  {'TCKR': 'APPL', 'PRICE': 200},
  {'TCKR': 'GOOG', 'PRICE': 90},
  {'TCKR': 'TSLA', 'PRICE': 120},
  {'TCKR': 'MSFT', 'PRICE': 150},
  {'TCKR': 'INTL', 'PRICE': 70},
  {'TCKR': 'ELLT', 'PRICE': 0}
]

def buy_stock_events(observer):
   for stock in stocks:
      if (stock['PRICE'] > 100):
        observer.on_next(stock['TCKR'])
   elif (stock['PRICE'] <= 0):
        observer.on_error(stock['TCKR'])
   observer.on_completed()

source = Observable.create(buy_stock_events)

source.subscribe(on_next=lambda value: print("Received Instruction to buy {0}".format(value)),
            on_completed=lambda: print("Completed trades"),
            on_error=lambda e: print(e))

Answer 1

Они обновили модуль RxPy.Установите 1.6.1, это решит проблему.Спасибо

Answer 2

Я нашел решение,

измените код с

from rx import Observable
source = Observable.create(buy_stock_events)

на

import rx
source = rx.Observable.create(buy_stock_events)

и он работает