diff --git a/src/signaling/client.go b/src/signaling/client.go index 9546a59..55b7051 100644 --- a/src/signaling/client.go +++ b/src/signaling/client.go @@ -261,7 +261,7 @@ func (c *Client) ReadPump() { conn.SetReadDeadline(time.Now().Add(pongWait)) messageType, reader, err := conn.NextReader() if err != nil { - if websocket.IsUnexpectedCloseError(err, + if _, ok := err.(*websocket.CloseError); !ok || websocket.IsUnexpectedCloseError(err, websocket.CloseNormalClosure, websocket.CloseGoingAway, websocket.CloseNoStatusReceived) { diff --git a/src/signaling/mcu_proxy.go b/src/signaling/mcu_proxy.go index 6a68c55..fa9b017 100644 --- a/src/signaling/mcu_proxy.go +++ b/src/signaling/mcu_proxy.go @@ -393,7 +393,7 @@ func (c *mcuProxyConnection) readPump() { conn.SetReadDeadline(time.Now().Add(pongWait)) _, message, err := conn.ReadMessage() if err != nil { - if websocket.IsUnexpectedCloseError(err, + if _, ok := err.(*websocket.CloseError); !ok || websocket.IsUnexpectedCloseError(err, websocket.CloseNormalClosure, websocket.CloseGoingAway, websocket.CloseNoStatusReceived) {