akka - 如何将数据从队列传递给客户端？

Question

我正在尝试使用akka-streams.

我有：

• A Server：当客户端连接服务器时，向他发送初始化数据。（这里没有问题）
• 队列：服务器定期填充它。大多数时候它是空的（这是一个问题）

我希望服务器在有东西时从队列中发送数据。我该怎么做？

标签： akkaakka-stream

Answer 1

我不确定我是否以正确的方式理解了你的问题背后的想法，但你可以使用Source.Queue来获得所需的行为。