cask.WsActor { casecask.Ws.Text(msg) => if(msg.toInt connection.send( cask.Ws.Text( ujson.Obj("index"-> mess。用Scala实现简单的Web和API服务器(34)。" />

用Scala实现简单的Web和API服务器(34)

)

)

).render

}

@cask.websocket("/subscribe")

defsubscribe= {

cask.WsHandler { connection =>

cask.WsActor {

casecask.Ws.Text(msg) =>

if(msg.toInt < messages.length){

connection.send(

cask.Ws.Text(

ujson.Obj("index"-> messages.length, "txt"-> messageList.render).render

)

)

}else{

openConnections += connection

}

casecask.Ws.Close(_, _) => openConnections -= connection

推荐阅读