From c8596b09bc030c92d3895ba9c40dc2c5fc696c83 Mon Sep 17 00:00:00 2001 From: gospider <2216403312@qq.com> Date: Thu, 10 Apr 2025 22:20:43 +0800 Subject: [PATCH] sync --- requests.go | 24 +++++++++++------------- 1 file changed, 11 insertions(+), 13 deletions(-) diff --git a/requests.go b/requests.go index 21c0ee6..60d7d24 100644 --- a/requests.go +++ b/requests.go @@ -346,22 +346,20 @@ func (obj *Client) request(ctx *Response) (err error) { if ctx.Body() != nil { ctx.body = ctx.Body().(*wrapBody) } - if ctx.StatusCode() != 101 { - if encoding := ctx.ContentEncoding(); encoding != "" { - var unCompressionBody io.ReadCloser - unCompressionBody, err = tools.CompressionHeadersDecode(ctx.Context(), ctx.Body(), encoding) - if err != nil { - if err != io.ErrUnexpectedEOF && err != io.EOF { - return - } - } - if unCompressionBody != nil { - ctx.response.Body = unCompressionBody + if encoding := ctx.ContentEncoding(); encoding != "" { + var unCompressionBody io.ReadCloser + unCompressionBody, err = tools.CompressionHeadersDecode(ctx.Context(), ctx.Body(), encoding) + if err != nil { + if err != io.ErrUnexpectedEOF && err != io.EOF { + return } } - if strings.Contains(ctx.response.Header.Get("Content-Type"), "text/event-stream") { - ctx.sse = newSSE(ctx) + if unCompressionBody != nil { + ctx.response.Body = unCompressionBody } } + if strings.Contains(ctx.response.Header.Get("Content-Type"), "text/event-stream") { + ctx.sse = newSSE(ctx) + } return }