fix(websocket): ensure resources are properly released by closing the manager in PeriodicWrite function

internal/net/gphttp/websocket/utils.go

@@ -82,6 +82,7 @@ func PeriodicWrite(c *gin.Context, interval time.Duration, get func() (any, erro
 		c.Error(apitypes.InternalServerError(err, "failed to upgrade to websocket"))
 		return
 	}
+	defer manager.Close()
 	err = manager.PeriodicWrite(interval, get)
 	if err != nil {
 		c.Error(apitypes.InternalServerError(err, "failed to write to websocket"))

internal/utils/io.go

@@ -141,7 +141,7 @@ func getHTTPFlusher(dst io.Writer) flushErrorInterface {
 
 const copyBufSize = synk.SizedPoolThreshold
 
-var bytesPool = synk.NewBytesPool()
+var bytesPool = synk.GetBytesPool()
 
 // Copyright 2009 The Go Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style