Agregado codigo para permitir reconexiones
This commit is contained in:
parent
e34c4bcc98
commit
623437edf9
@ -1,6 +1,7 @@
|
|||||||
package dev.araozu
|
package dev.araozu
|
||||||
|
|
||||||
import io.ktor.http.cio.websocket.*
|
import io.ktor.http.cio.websocket.*
|
||||||
|
import kotlinx.coroutines.isActive
|
||||||
|
|
||||||
object GestorJuegos {
|
object GestorJuegos {
|
||||||
|
|
||||||
@ -43,7 +44,7 @@ object GestorJuegos {
|
|||||||
|
|
||||||
private suspend fun broadcast(juego: Juego, mensaje: String) {
|
private suspend fun broadcast(juego: Juego, mensaje: String) {
|
||||||
juego.conexiones.forEach { (_, socket) ->
|
juego.conexiones.forEach { (_, socket) ->
|
||||||
socket.send(Frame.Text(mensaje))
|
if (socket.isActive) socket.send(Frame.Text(mensaje))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user