java - 保持间隔 Observable 在 Java 中运行

Question

我是 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() 调用此方法，进程会立即退出。如何避免进程退出？

Answer 1

sleep 可能会导致错误。相反，请检查blockingSubscribe 运算符。