代码之家 › 专栏 › 技术社区 › Diafotismos

启动RxJava2 Observable。间隔()没有初始延迟?

reactivex rx-java2 rx-java android java

Diafotismos · 技术社区 · 7 年前

我正在使用RxJava2 Observable每秒重复一次操作,然后将结果发布到Android布局中的文本视图中。我现在的代码(下面)运行得很好,但我希望它在执行时没有初始延迟。

Disposable disposable = Observable.interval(1000, java.util.concurrent.TimeUnit.MILLISECONDS)
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(aLong -> myMethod());

我注意到其他使用RxJS的人 timer() 而不是 interval() 实现0延迟。有没有办法用RxJava2做到这一点?

1 回复 | 直到 7 年前

riyaz-ali 7 年前

~~有一个 Observable.timer(long delay, TimeUnit unit, Scheduler scheduler) 在里面 RxJava 2 . 你可以试着用它。~~

更新1:
对于 interval 从初始延迟开始,然后以固定间隔发射,您可以使用 Observable.interval(long initialDelay, long period, TimeUnit unit, Scheduler scheduler)

推荐文章

Gissipi_453 · 在RxJava 2中的可观察对象中发出字符串数组时出现“不兼容类型”错误

6 年前

Damn Vegetables · 当N个事件中的任何一个发生时执行,但使用所有其他事件的最后结果

6 年前

Damn Vegetables · 如何压缩(s1,o1),其中s1只发生一次,o1发生多次?

6 年前

CaHa · 如何在rxjava中等待改装响应

6 年前

noloman amram99 · Android和Room:插入作品,查询不

6 年前

Martin · 可观察到。具有状态的生成器,其中异步更新新状态

6 年前

Victor Dmitrienko · RxJava解Bounce运算符取决于消息

6 年前

idunnololz adsion · 调用dispose()之前是否需要检查isDisposed()?

6 年前

Josh Laird · 轮询第二个URL,直到JSON返回预期参数

6 年前

n0shadow · RxJava:为一个完整表列表指定最大并发性

6 年前