是的,Akka 的 BroadcastHub 可以用来实现 Akka 的 Sink.fromPublisher。BroadcastHub 可以接收来自多个源的数据,并将其广播到多个接收器。您可以将您的 Publisher 连接到 BroadcastHub,并使用 Sink.fromSubscriber 将其连接到 Akka Stream 中作为一个 Sink。这将使您能够将数据从您的 Publisher 流式传输到 Akka Stream 中,并将其传递给任意数量的接收器。

Akka BroadcastHub 实现 Sink.fromPublisher?

原文地址: https://www.cveoy.top/t/topic/lIIC 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录