From 7c2c268bc71d4a27370b81c92881cc7351cb792b Mon Sep 17 00:00:00 2001
From: lz1998 <875543533@qq.com>
Date: Wed, 4 Aug 2021 22:19:50 +0800
Subject: [PATCH] fix ws

---
 pkg/safe_ws/safe_ws.go | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/pkg/safe_ws/safe_ws.go b/pkg/safe_ws/safe_ws.go
index d40d952..64a270a 100644
--- 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)
+			})
 		}
 	})