fix ws

TMSTB · Aug 4, 2021 · 7c2c268 · 7c2c268
1 parent 85d05c2
commit 7c2c268
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pkg/safe_ws/safe_ws.go b/pkg/safe_ws/safe_ws.go
@@ -74,7 +74,9 @@ func NewSafeWebSocket(conn *websocket.Conn, OnRecvMessage func(ws *SafeWebSocket
 				}
 				continue
 			}
-			ws.OnRecvMessage(ws, messageType, data)
+			util.SafeGo(func() {
+				ws.OnRecvMessage(ws, messageType, data)
+			})
 		}
 	})