internal/biz/router.go

@@ -214,11 +214,6 @@ func sendWithTimeout(c *websocket.Conn, data entitys.Response, timeout time.Dura
 
 	done := make(chan error, 1)
 	go func() {
-		defer func() {
-			if r := recover(); r != nil {
-				done <- fmt.Errorf("panic in MsgSend: %v", r)
-			}
-		}()
 		done <- entitys.MsgSend(c, data)
 	}()
 

internal/entitys/response.go

@@ -47,8 +47,6 @@ func MsgSet(msgType ResponseType, msg string, done bool) []byte {
 }
 
 func MsgSend(c *websocket.Conn, msg Response) error {
-	// 检查上下文是否已取消
-
 	jsonByte, _ := json.Marshal(msg)
 
 	return c.WriteMessage(websocket.TextMessage, jsonByte)