首页 > 解决方案 > 如何让 Observable.interval() 在 RxJava 中立即触发?

问题描述

我想创建一个每 5 秒(0 秒、5 秒、10 秒等)发出值的可观察对象,当我使用时Observable.interval(5, TimeUnit.SECONDS),在发出第一个事件之前有 5 秒延迟,当我用谷歌搜索并尝试使用时,Observable.timer我被它的Scheduler scheduler参数弄糊涂了。

我目前的解决方法(在我找到一些类似问题的答案之后)是添加.startsWith(0L)

Observable.interval(5, TimeUnit.SECONDS).startsWith(0L)

是否有接受延迟(或默认为 0)的运算符以及我可以在哪里指定间隔?

标签: javareactive-programmingrx-java2

解决方案


推荐阅读