diff --git a/wshandler/wshandler_peer.go b/wshandler/wshandler_peer.go index 276f886..94b66b9 100644 --- a/wshandler/wshandler_peer.go +++ b/wshandler/wshandler_peer.go @@ -272,7 +272,12 @@ func (ws *websocketPeerHandler[T]) upgrade_core(conn *websocket.Conn, accid prim response = append(response, j...) } } - c.WriteMessage(websocket.BinaryMessage, response) + pmsg, err := websocket.NewPreparedMessage(websocket.BinaryMessage, response) + if err != nil { + logger.Println("websocket.NewPreparedMessage failed :", err) + } else { + c.WritePreparedMessage(pmsg) + } } else { cmd := make([]byte, flag[0]) r.Read(cmd)