chuan/CLIProxyAPI
1
0
Fork 0
mirror of https://github.com/router-for-me/CLIProxyAPI.git synced 2026-02-03 21:10:51 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #515 from teeverc/fix/response-rewriter-streaming-flush

Browse Source 
fix(amp): flush response buffer after each streaming chunk write
This commit is contained in:
Luis Pater
2025-12-14 13:26:05 +08:00
committed by GitHub
parent b6ad243e9e cd8c86c6fb
commit 2fe83723f2
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
internal/api/modules/amp/response_rewriter.go
View File

@@ -39,7 +39,13 @@ func (rw *ResponseRewriter) Write(data []byte) (int, error) {
} }
if rw.isStreaming { if rw.isStreaming {
return rw.ResponseWriter.Write(rw.rewriteStreamChunk(data)) n, err := rw.ResponseWriter.Write(rw.rewriteStreamChunk(data))
if err == nil {
if flusher, ok := rw.ResponseWriter.(http.Flusher); ok {
flusher.Flush()
}
}
return n, err
} }
return rw.body.Write(data) return rw.body.Write(data)
} }