如何使用RxSwift Observable.interval？

发布时间：2020-12-14 04:44:32 所属栏目：百科来源：网络整理

导读：我试图以给定的时间间隔在“脉冲”上发出序列.一切都是新的Rx,但认为这样做： import RxSwiftlet db = DisposeBag()_ = ObservableInt.interval(1.0,scheduler: MainScheduler.instance) .debug("interval") .subscribe(onNext: { print($0) }) .addDisposab

我试图以给定的时间间隔在“脉冲”上发出序列.一切都是新的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

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!