在观察者可以订阅之前,我有一个外部热源在推送数值。订阅后,较晚的观察者应收到最新的值以及此后的每一个值。为此,我使用了以下代码(相关代码行标记为‘<’,这里的s Subject只是为了能够创建最简单的示例,实际上热源的工作方式不同): // irrelevant, just to send values
我使用的是反应堆核心。Flux<String> flux = Flux.<String>create(sink -> sink.next("test")) .refCount();
flux.next().subscribe(System.out::println); // The exception is thrown here!test实际输出:Exception in