根据 Reactive Stream 范例，
目前，我们主要关注冷流。这些是易于处理的静态、固定长度的流。反应式更现实的用例可能是无限发生的事情。例如，我们可以有一系列需要不断响应的鼠标移动或 Twitter 提要。这些类型的流被称为热流，因为它们总是在运行并且可以在任何时间点订阅，而忽略了数据的开始。
那么我们如何实现这个热流呢？
这可以使用 ConnectableFlux 完成，如下所示：
ConnectableFlux<Object> publish = Flux.create(fluxSink -> {
while(true) {
fluxSink.next(System.currentTimeMillis());
}
})
.publish();
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
我来说两句