我是新上rxjava,我想执行一个轮询任务每2秒50次,也是它,如果在任务中的一些条件满足,我将尝试使用可能会终止Observable.interval,但是我发现没有办法来终止它除了扔例外,有没有其他运营商来实现我的目标？BTW此功能用作API以提供可观察对象,因此我无法通过取消描述来控制订户和终止.
Observable.interval(timeout, interval, TimeUnit.SECONDS)
.flatmap(task - > task)
rx-java ×1