Cómo refactorizar este código utilizando secuencias de akka.
La idea es mantener el canal abierto para usarlo más tarde. En playframework 2.5.x, la documentación dice que debe usar secuencias de akka, pero no dice nada sobre cómo lograr este ejemplo. ¿Alguien puede ayudarme?
import play.api.mvc._
import play.api.libs.iteratee._
import play.api.libs.concurrent.Execution.Implicits.defaultContext
def socket = WebSocket.using[String] { request =>
// Concurrent.broadcast returns (Enumerator, Concurrent.Channel)
val (out, channel) = Concurrent.broadcast[String]
// log the message to stdout and send response back to client
val in = Iteratee.foreach[String] {
msg => println(msg)
// the Enumerator returned by Concurrent.broadcast subscribes to the channel and will
// receive the pushed messages
channel push("I received your message: " + msg)
}
(in,out)
}