This commit is contained in:
gospider
2025-08-17 21:23:53 +08:00
parent b7e9168c80
commit c3ed6ea481
3 changed files with 14 additions and 10 deletions

View File

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