如何使用RxSwift 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

相关文章

软件简介:蓝湖辅助工具,减少移动端开发中控件属性的复制和粘...
现实生活中,我们听到的声音都是时间连续的,我们称为这种信...
前言最近在B站上看到一个漂亮的仙女姐姐跳舞视频,循环看了亿...
【Android App】实战项目之仿抖音的短视频分享App(附源码和...
前言这一篇博客应该是我花时间最多的一次了,从2022年1月底至...
因为我既对接过session、cookie,也对接过JWT,今年因为工作...