fix: 流式换行符修复

tbphp · tbphp · commit b2374841e561 · 2025-07-13T11:04:24.000+08:00
diff --git 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
 		}

Original file line number	Diff line number	Diff line change
`@@ -24,6 +24,7 @@ func (ps ProxyServer) handleStreamingResponse(c gin.Context, resp *http.Respon`
`24`	`24`	`}`
`25`	`25`
`26`	`26`	`scanner := bufio.NewScanner(resp.Body)`
	`27`	`+ scanner.Buffer(make([]byte, 0, 641024), 10241024)`
`27`	`28`	`for scanner.Scan() {`
`28`	`29`	`select {`
`29`	`30`	`case <-c.Request.Context().Done():`
`@@ -36,7 +37,7 @@ func (ps ProxyServer) handleStreamingResponse(c gin.Context, resp *http.Respon`
`36`	`37`	`logUpstreamError("writing stream to client", err)`
`37`	`38`	`return`
`38`	`39`	`}`
`39`		`- if _, err := c.Writer.Write([]byte("\n\n")); err != nil {`
	`40`	`+ if _, err := c.Writer.Write([]byte("\n")); err != nil {`
`40`	`41`	`logUpstreamError("writing stream newline to client", err)`
`41`	`42`	`return`
`42`	`43`	`}`