我正在尝试使用akka-streams编写tcp服务器。
我有：
- 服务器：当客户端连接时，服务器会向他发送启动数据。(这里没有问题(
- 队列：服务器定期填充它。大多数时候它是空的(这里有个问题(
我希望服务器在有数据时从队列发送数据。我该怎么做？
我不确定你的问题背后的想法是否正确，但你可以使用Source。排队以获得所需的行为。