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

【问题标题】：type object 'ObservableBase' has no attribute 'create' RxPy类型对象“ObservableBase”没有属性“创建”RxPy
【发布时间】：2019-07-10 20:41:39
【问题描述】：

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

类型对象'ObservableBase'没有属性'create'

我使用的是 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))

【问题讨论】：

为什么不只是rx.create()？
谢谢你的建议，我已经找到解决办法了

标签： python python-3.x pypi rx-py

【解决方案1】：

他们更新了 RxPy 模块。安装1.6.1，问题就解决了。谢谢

【讨论】：

【解决方案2】：

我找到了解决办法，

修改代码

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

到

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

它正在工作

【讨论】：