Merge pull request #8 from WJQSERVER-STUDIO/dev

replace to iox

Author: WJQSERVER

go.mod

@@ -5,7 +5,7 @@ go 1.24.4
 require github.com/valyala/bytebufferpool v1.0.0 // indirect
 
 require (
-	github.com/WJQSERVER-STUDIO/go-utils/copyb v0.0.6
+	github.com/WJQSERVER-STUDIO/go-utils/iox v0.0.2
 	github.com/go-json-experiment/json v0.0.0-20250714165856-be8212f5270d
 	golang.org/x/net v0.42.0
 )

go.sum

@@ -1,5 +1,5 @@
-github.com/WJQSERVER-STUDIO/go-utils/copyb v0.0.6 h1:/50VJYXd6jcu+p5BnEBDyiX0nAyGxas1W3DCnrYMxMY=
-github.com/WJQSERVER-STUDIO/go-utils/copyb v0.0.6/go.mod h1:FZ6XE+4TKy4MOfX1xWKe6Rwsg0ucYFCdNh1KLvyKTfc=
+github.com/WJQSERVER-STUDIO/go-utils/iox v0.0.2 h1:AiIHXP21LpK7pFfqUlUstgQEWzjbekZgxOuvVwiMfyM=
+github.com/WJQSERVER-STUDIO/go-utils/iox v0.0.2/go.mod h1:mCLqYU32bTmEE6dpj37MKKiZgz70Jh/xyK9vVbq6pok=
 github.com/go-json-experiment/json v0.0.0-20250714165856-be8212f5270d h1:+d6m5Bjvv0/RJct1VcOw2P5bvBOGjENmxORJYnSYDow=
 github.com/go-json-experiment/json v0.0.0-20250714165856-be8212f5270d/go.mod h1:TiCD2a1pcmjd7YnhGH0f/zKNcCD06B029pHhzV23c2M=
 github.com/valyala/bytebufferpool v1.0.0 h1:GqA5TC/0021Y/b9FG4Oi9Mr3q7XYx6KllzawFIhcdPw=

httpc.go

@@ -21,7 +21,7 @@ import (
 	"github.com/go-json-experiment/json"
 	"golang.org/x/net/proxy"
 
-	"github.com/WJQSERVER-STUDIO/go-utils/copyb"
+	"github.com/WJQSERVER-STUDIO/go-utils/iox"
 )
 
 // 错误定义
@@ -795,7 +795,7 @@ func (c *Client) retryRoundTripper(next http.RoundTripper) http.RoundTripper {
 
 			// 在重试前，确保关闭当前失败的响应体以复用连接
 			if resp != nil && resp.Body != nil {
-				copyb.Copy(io.Discard, resp.Body)
+				iox.Copy(io.Discard, resp.Body)
 				resp.Body.Close()
 			}
 
@@ -1092,9 +1092,9 @@ func (c *Client) decodeTextResponse(resp *http.Response) (string, error) {
 		return "", c.errorResponse(resp)
 	}
 
-	bodyBytes, err := copyb.ReadAll(resp.Body)
+	bodyBytes, err := iox.ReadAll(resp.Body)
 	if err != nil {
-		return "", fmt.Errorf("%w: %v", ErrDecodeResponse, err)
+return "", fmt.Errorf("%w: %s", err, ErrDecodeResponse)
 	}
 	return string(bodyBytes), nil
 }
@@ -1103,9 +1103,9 @@ func (c *Client) decodeBytesResponse(resp *http.Response) ([]byte, error) {
 	if resp.StatusCode >= 400 {
 		return nil, c.errorResponse(resp)
 	}
-	bodyBytes, err := copyb.ReadAll(resp.Body)
+	bodyBytes, err := iox.ReadAll(resp.Body)
 	if err != nil {
-		return nil, fmt.Errorf("%w: %v", ErrDecodeResponse, err)
+return nil, fmt.Errorf("%w: %s", err, ErrDecodeResponse)
 	}
 	return bodyBytes, nil
 }
@@ -1146,14 +1146,14 @@ func (c *Client) errorResponse(resp *http.Response) error {
 
 	limitedReader := io.LimitReader(resp.Body, maxErrorBodyRead)
 	readErr := func() error { // 使用匿名函数捕获读取错误
-		_, err := copyb.Copy(buf, limitedReader)
+		_, err := iox.Copy(buf, limitedReader)
 		return err
 	}() // 立即执行
 
 	// *** 关键: 丢弃剩余的响应体 ***
 	const maxDiscardSize = 64 * 1024
 	discardErr := func() error { // 使用匿名函数捕获丢弃错误
-		_, err := copyb.CopyN(io.Discard, resp.Body, maxDiscardSize)
+		_, err := iox.CopyN(io.Discard, resp.Body, maxDiscardSize)
 		// 如果错误是 EOF，说明我们已经读完了或者超出了 maxDiscardSize，这不是一个需要报告的错误
 		if errors.Is(err, io.EOF) {
 			return nil