я написал простой сокет клиент с Аккой-IO, потребляющие строки с сервером сокета (он посылает строки, разделенные \ п):Play: трансляция сообщений из актеров серверных посланных событий
class SocketClient(endpoint: InetSocketAddress) extends Actor {
override def preStart() {
IOManager(context.system).connect(endpoint)
}
def receive = {
case IO.Read(socket, bytes) => ??? ! bytes.utf8String
}
}
Мне нужно транслировать строки, полученные с помощью Server-Sent Events, всем клиентам, которые его запросили. Как определить Enumerator со всеми сообщениями, полученными участниками, которые будут доступны в виде потока из контроллера Play?