From 25cd7dfbe22d7011e594e79208119065b03ca703 Mon Sep 17 00:00:00 2001 From: qydysky <32743305+qydysky@users.noreply.github.com> Date: Mon, 22 Aug 2022 01:04:00 +0800 Subject: [PATCH] update --- reqf/Reqf.go | 38 +++++++++++++++++++------------------- 1 file changed, 19 insertions(+), 19 deletions(-) diff --git a/reqf/Reqf.go b/reqf/Reqf.go index da0dc06..de6a337 100644 --- a/reqf/Reqf.go +++ b/reqf/Reqf.go @@ -34,7 +34,7 @@ type Rval struct { Cookies []*http.Cookie SaveToPath string - SaveToChan chan []byte + SaveToChan chan []byte // deprecated SaveToPipeWriter *io.PipeWriter Header map[string]string @@ -169,7 +169,7 @@ func (t *Req) Reqf_1(val Rval) (err error) { if _, ok := Header["Accept-Encoding"]; !ok { Header["Accept-Encoding"] = "gzip, deflate, br" } - if val.SaveToPath != "" || val.SaveToChan != nil || val.SaveToPipeWriter != nil { + if val.SaveToPath != "" || val.SaveToPipeWriter != nil { Header["Accept-Encoding"] = "identity" } if _, ok := Header["User-Agent"]; !ok { @@ -255,23 +255,23 @@ func (t *Req) Reqf_1(val Rval) (err error) { defer val.SaveToPipeWriter.Close() ws = append(ws, val.SaveToPipeWriter) } - if val.SaveToChan != nil { - r, w := io.Pipe() - go func() { - buf := make([]byte, 1<<16) - for { - n, e := r.Read(buf) - if n != 0 { - val.SaveToChan <- buf[:n] - } else if e != nil { - defer close(val.SaveToChan) - break - } - } - }() - defer w.Close() - ws = append(ws, w) - } + // if val.SaveToChan != nil { + // r, w := io.Pipe() + // go func() { + // buf := make([]byte, 1<<16) + // for { + // n, e := r.Read(buf) + // if n != 0 { + // val.SaveToChan <- buf[:n] + // } else if e != nil { + // defer close(val.SaveToChan) + // break + // } + // } + // }() + // defer w.Close() + // ws = append(ws, w) + // } if !val.NoResponse { var buf bytes.Buffer defer func() { -- 2.39.2