ソケット サーバーからの文字列を使用する Akka-IO を使用した単純なソケット クライアントを作成しました (\n で区切られた文字列を送信します)。
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 を使用して受信した文字列を、それを要求したすべてのクライアントにブロードキャストする必要があります。アクターが受信したすべてのメッセージを Play のコントローラーからのストリームとして利用できるように列挙子を定義するにはどうすればよいですか?