diff --git a/server/websockets/client.go b/server/websockets/client.go index efbc634..ddefa1f 100644 --- a/server/websockets/client.go +++ b/server/websockets/client.go @@ -60,7 +60,7 @@ func (c *Client) readPump() { }() for { - _, _, err := c.conn.ReadMessage() + _, _, err := c.conn.NextReader() if err != nil { if websocket.IsUnexpectedCloseError(err, websocket.CloseGoingAway, websocket.CloseAbnormalClosure) { logger.Log().Errorf("[websocket] error: %v", err)