From b2374841e5611a8f949d687715022e6fa5ea6b66 Mon Sep 17 00:00:00 2001 From: tbphp Date: Sun, 13 Jul 2025 11:04:24 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E6=B5=81=E5=BC=8F=E6=8D=A2=E8=A1=8C?= =?UTF-8?q?=E7=AC=A6=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/proxy/response_handlers.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/internal/proxy/response_handlers.go b/internal/proxy/response_handlers.go index 979aee4..116db28 100644 --- a/internal/proxy/response_handlers.go +++ b/internal/proxy/response_handlers.go @@ -24,6 +24,7 @@ func (ps *ProxyServer) handleStreamingResponse(c *gin.Context, resp *http.Respon } scanner := bufio.NewScanner(resp.Body) + scanner.Buffer(make([]byte, 0, 64*1024), 1024*1024) for scanner.Scan() { select { case <-c.Request.Context().Done(): @@ -36,7 +37,7 @@ func (ps *ProxyServer) handleStreamingResponse(c *gin.Context, resp *http.Respon logUpstreamError("writing stream to client", err) return } - if _, err := c.Writer.Write([]byte("\n\n")); err != nil { + if _, err := c.Writer.Write([]byte("\n")); err != nil { logUpstreamError("writing stream newline to client", err) return }