如何解决RxJava如何创建一个间隔，该间隔具有以不同延迟执行的多个作业？
我对RxJava非常陌生，所以我的问题可能完全是愚蠢的，但是我不知道该怎么做。
所以我有N个作业实现了以下接口
interface Worker {
int interval();
void job();
}
我想要实现的是一种类似计时器的功能，每次经过Worker时，就会调用这些job() s interval()函数。
到目前为止我尝试过的
Observable.fromArray(worker1,worker2)
.flatMap(worker -> Observable.just(worker).delay(worker.delay(),TimeUnit.SECONDS))
.subscribe(Worker::job);
这很好，工作在给定时间过去之后异步执行。
但这仅执行一次。我了解我需要以某种方式使用interval()运算符，但无法将其包围。
预先感谢
解决方法
如果我正确理解了您的问题，则需要执行以下操作：
RazorClassLibrary1您应注意，在此实现中，您的Observable.fromArray(worker1,worker2)
.flatMap { worker ->
Observable.interval(worker.interval(),TimeUnit.SECONDS)
.flatMap { Observable.just(worker).delay(worker.delay(),TimeUnit.SECONDS) }
}
.subscribe(Worker::job)
呼叫将以意外的顺序进行
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。