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



我正在尝试在给定时间间隔上发出"脉冲"序列。对于所有RX来说,完全是新的,但认为这会做到:

import RxSwift
let db = DisposeBag()
_ = Observable<Int>.interval(1.0, scheduler: MainScheduler.instance)
    .debug("interval")
    .subscribe(onNext: {
        print($0)
    })
    .addDisposableTo(db)

,但仅输出:

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

,仅此而已。我在这里不了解什么?

您的代码没有错。处置袋还活着。但是,操场执行后立即结束,因此问题。

为了告诉操场在执行所有操作后,要继续运行,您必须导入PlaygroundSupport并告诉页面继续运行:

import RxSwift
import PlaygroundSupport
let db = DisposeBag()
Observable<Int>.interval(1.0, scheduler: MainScheduler.instance)
    .debug("interval")
    .subscribe(onNext: {
        print($0)
    })
    .addDisposableTo(db)
PlaygroundPage.current.needsIndefiniteExecution = true

最新更新