WebSocket.kt

webSocket {
        
        try {
            incoming.consumeEach { frame ->
                if (frame is Frame.Text) {
                    val frameTextReceived = frame.readText()
                    val jsonObject = JsonParser.parseString(frameTextReceived).asJsonObject
                    val type = when (jsonObject.get("type").asString) {
                        TYPE_GAME_MOVE -> GameMove::class.java
                        TYPE_DISCONNECT_REQUEST -> DisconnectRequest::class.java
                        else -> BaseModel::class.java
                    }
                    val message = gson.fromJson(frameTextReceived, type)
                    
                    when(message) {
                       is GameMove -> // Handle Game Move
                       is DisconnectRequest -> // Handle disconnect request
                    }
                }
            }
        } catch (e: Exception) {
            e.printStackTrace()
        } finally {
            // Handle Socket Closed
        }
    }