python - 类型对象“ObservableBase”没有属性“创建”RxPy

Question

我正在尝试了解 RxPy 的工作原理，但出现此错误

类型对象“ObservableBase”没有属性“创建”

我正在使用 python 3.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)

它正在工作