我是 Java 线程的新手,想知道如何保持以下 Observable 运行,
private void init() {
System.out.println("Running...");
Observable o = Observable.interval(5, TimeUnit.SECONDS)
.flatMap(o -> serverService.listServers("all"))
.retryWhen(o -> o.flatMap(s -> Observable.timer(30, TimeUnit.SECONDS)))
.subscribe(serverModels -> System.out.println("onNext"),
e -> System.out.println("ERROR " + e),
() -> System.out.println("Completed"));
}
如果我从 main() 调用此方法,进程会立即退出。如何避免进程退出?
最佳答案
sleep 可能会导致错误。相反,请检查blockingSubscribe 运算符。
关于java - 保持间隔 Observable 在 Java 中运行,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/46711059/