RxJava2：不要在`repeatWhen`中重复

概述我有一个Observable我想定期重复,但只是在一个条件下：apiInterface.getData()//returnsObservable<Data>...//processingishappeninghere.toList().repeatWhen(completed->{if(autoReload){//Repeatevery3secondsreturncompleted.delay

我有一个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(只执行一次链接)？

解决方法:

您必须通过响应项目的信号完成的内容对完成指示器做出反应,例如：

completed.takeWhile(v -> false);

不幸的是,empty()在那里不起作用,因为它在源甚至可以运行之前立即完成序列.

总结

以上是内存溢出为你收集整理的RxJava2：不要在`repeatWhen`中重复全部内容，希望文章能够帮你解决RxJava2：不要在`repeatWhen`中重复所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。