Как передать данные клиенту из очереди?

Question

Я пытаюсь написать tcp-сервер, используя akka-streams.

У меня есть:

• Сервер: когда клиент подключается, сервер отправляет ему данные инициации. (здесь нет проблем)
• Очередь: сервер периодически ее заполняет. Большую часть времени он пуст (здесь проблема)

Я хочу, чтобы сервер отправлял данные из очереди, когда что-то есть. Как я могу это сделать?

Answer 1

Я не уверен, правильно ли я понял, что лежит в основе вашей проблемы, но вы, возможно, можете воспользоваться Source.Queue , чтобы получить желаемое поведение.