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-01 11:38:17 +08:00
parent 377bd4eb6a
commit c924f57df3
1 changed files with 8 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
conn.go
View File

@@ -20,14 +20,15 @@ func taskMain(conn http1.Conn, task *reqTask) (err error) {
err = err2 err = err2
} }
} }
if err == nil { if err != nil {
task.cnl(tools.ErrNoErr)
} else {
task.cnl(err) task.cnl(err)
} } else {
var bodyCtx context.Context
if err == nil && task.reqCtx.response != nil && task.reqCtx.response.Body != nil { if task.reqCtx.response != nil && task.reqCtx.response.Body != nil {
if bodyCtx := task.reqCtx.response.Body.(*http1.Body).Context(); bodyCtx != nil { bodyCtx = task.reqCtx.response.Body.(*http1.Body).Context()
}
task.cnl(tools.ErrNoErr)
if bodyCtx != nil {
select { select {
case <-task.reqCtx.Context().Done(): case <-task.reqCtx.Context().Done():
if context.Cause(task.reqCtx.Context()) != tools.ErrNoErr { if context.Cause(task.reqCtx.Context()) != tools.ErrNoErr {