python - RxPY - 如何使用 stop_and_wait？

Question

我尝试在 Python 中翻译以下 JavaScript 代码示例：

import Rx from "rx"

let source = Rx.Observable.interval(1000)
  .timestamp()
  .controlled();

source.stopAndWait().subscribe(
  (result) => console.log("onNext: ", result),
  (error) => console.log("onError: ", error),
  () => console.log("Done!")
);

该片段取自RxJS 发行说明。我的 Python 解释如下所示：

from __future__ import print_function
from rx import Observable


source = Observable.interval(1000).timestamp().controlled()
source.stop_and_wait().subscribe(
    on_next=lambda x: print("on_next %s" % x),
    on_error=lambda e: print("on_error %s" % e)
)

不幸的是，虽然 JavaScript 版本运行良好，但 Python 版本由于“StopAndWaitObservable”对象没有“订阅”属性而失败。

Answer 1

该问题的修复已合并到 rx 库开发线。有了修复 Python 版本就像 JavaScript 一样工作。