在 Java 中保持间隔 Observable 运行

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

睡觉会导致错误。而是检查 blockingSubscribe 运算符。

在 Java 中保持间隔 Observable 运行

Keep interval Observable running in Java

java

intervals

rx-java