2013-03-17 2 views
1

я написал простой сокет клиент с Аккой-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?

ответ

2

Возможно, эта ссылка поможет вам? Отправка сообщений клиентам с участием участников и счетчика.

Blog