RxJava 中的循环调度程序

recurring scheduler in RxJava

我想从 ListView 中删除旧内容,因此我在 Activity.

中将循环调度程序定义为处理程序
private Handler handler = new Handler();
private Runnable runnableCode = new Runnable() {
    @Override
    public void run() {
        doSomethingOnRecyclerView();
        handler.postDelayed(runnableCode, 2000);
    }
};
handler.post(runnableCode);

它有效,但是,我正在重构应用程序以使用 RxJava、mvp 和 dagger。如何在 RxJava 中执行循环调度程序? 将它保存在 MVP 架构中的什么位置,在 Presenter 中?

我会让处理程序存在于演示者中 class 并在每个时间间隔调用适当的视图方法。使用 RX,您可以拥有一个每 x 秒发射一次的发射器(或可流动的?)。这将完成与您的代码相同的事情。

确保将调度程序连接到演示者的生命周期