package/requests
1
0
Fork 0
mirror of https://github.com/gospider007/requests.git synced 2025-12-24 13:57:52 +08:00
Code Issues Packages Projects Releases Wiki Activity

sync

Browse Source
This commit is contained in:
gospider
2025-08-17 14:39:20 +08:00
parent 69ad730363
commit 48f9f55bcf
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
compressConn.go
View File

@@ -147,13 +147,14 @@ type ReaderCompression struct {
closeFunc func()
}
func (obj *ReaderCompression) Read(p []byte) (int, error) {
func (obj *ReaderCompression) Read(p []byte) (n int, err error) {
obj.lock.Lock()
defer obj.lock.Unlock()
if obj.closed {
return 0, errors.New("closed")
return 0, errors.New("read closed")
}
return obj.c.Read(p)
n, err = obj.c.Read(p)
return
}
func (obj *ReaderCompression) Close() error {
obj.lock.Lock()
@@ -179,7 +180,7 @@ func (obj *WriterCompression) Write(p []byte) (int, error) {
obj.lock.Lock()
defer obj.lock.Unlock()
if obj.closed {
return 0, errors.New("closed")
return 0, errors.New("write closed")
}
n, err := obj.c.Write(p)
if err != nil {