如何使用 RxSwift Observable<Int>.interval？

Question

我正在尝试以给定的时间间隔以“脉冲”方式发出序列。对所有 Rx 都是全新的，但认为这样做就可以了：

import RxSwift
let db = DisposeBag()

_ = Observable<Int>.interval(1.0, scheduler: MainScheduler.instance)
    .debug("interval")
    .subscribe(onNext: {
        print([=11=])
    })
    .addDisposableTo(db)

但它只输出：

2017-09-25 06:12:41.161: interval -> subscribed

仅此而已。我在这里有什么不明白的？

Answer 1

您的代码没有任何问题。处理袋应该是活的。但是，操场执行在最后一条指令为运行后立即结束，因此出现了问题。

为了让 playground 在执行完所有内容后继续运行ning，您必须导入 PlaygroundSupport 并告诉页面继续运行ning:

import RxSwift
import PlaygroundSupport

let db = DisposeBag()

Observable<Int>.interval(1.0, scheduler: MainScheduler.instance)
    .debug("interval")
    .subscribe(onNext: {
        print([=10=])
    })
    .addDisposableTo(db)

PlaygroundPage.current.needsIndefiniteExecution = true

如何使用 RxSwift Observable<Int>.interval？

How to use RxSwift Observable<Int>.interval?

swift

rx-swift