【发布时间】:2020-08-22 16:16:47
【问题描述】:
我想创建一个以 100 毫秒间隔发出事件的 observable。
我尝试使用rx.interval:
import rx
tick = rx.interval(100)
tick.subscribe(on_next=lambda i: print(i))
进程未运行,并提供一次性作为输出:
<rx.disposable.disposable.Disposable object at 0x7f7eac712dd8>
我怎样才能完成这项工作?
【问题讨论】: