fix ws

lz1998 · lz1998 · commit 7c2c268bc71d · 2021-08-04T22:19:50.000+08:00
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)
+			})
 		}
 	})
 

Original file line number	Diff line number	Diff line change
`@@ -74,7 +74,9 @@ func NewSafeWebSocket(conn websocket.Conn, OnRecvMessage func(ws SafeWebSocket`
`74`	`74`	`}`
`75`	`75`	`continue`
`76`	`76`	`}`
`77`		`- ws.OnRecvMessage(ws, messageType, data)`
	`77`	`+ util.SafeGo(func() {`
	`78`	`+ ws.OnRecvMessage(ws, messageType, data)`
	`79`	`+ })`
`78`	`80`	`}`
`79`	`81`	`})`
`80`	`82`