java - RxJava2 : Repeat conditonally/don't repeat in `repeatWhen`

Question

我有一个 Observable，我想定期重复，但仅限于以下条件:

apiInterface.getData() // returns Observable<Data>
... // processing is happening here
.toList()
.repeatWhen(completed -> {
    if (autoReload){
        // Repeat every 3 seconds
        return completed.delay(3, TimeUnit.SECONDS);
    } else {
        return ??? // What do I have to return that it does not repeat?
    }
})
.subscribe(list -> callbackInterface.success(list));

我的问题是:我必须在 else 语句中返回什么才能不重复 Observable(只执行一次链)？

Answer 1

您必须对完成指示器使用react，以表示对某个项目的响应已完成，例如:

completed.takeWhile(v -> false);

不幸的是，empty() 在那里不起作用，因为它甚至在源代码运行之前就立即完成了序列。