Reactor，如何保持应用程序活着

Question

序列是异步的，因此这将立即将控制权返回给调用线程。

public static void main(String[] args) {
    Flux<Long> tick = Flux.interval(Duration.ofSeconds(1));
    Flux<String> ticktock = tick.map(e -> e % 2 == 0 ? "tick" : "tock");
    ticktock
            .log()
            .subscribe(System.out::println);
}

在订阅者消耗无限流量时，保持程序活动的正确方法是什么？

Project Reactor 中有什么东西可以完成这项工作吗？还是我应该诉诸诸如 while(true) {} 或 Thread.sleep 之类的东西？

Answer 1

System.out.println("Hit 'Enter' to terminate");
System.in.read();

在您的main() 末尾。 这样程序将被阻塞，直到键盘交互。