diff --git a/interceptor/middleware/loggingresponsewriter.go b/interceptor/middleware/loggingresponsewriter.go index 0ebb9c6c7..9c893f1c1 100644 --- a/interceptor/middleware/loggingresponsewriter.go +++ b/interceptor/middleware/loggingresponsewriter.go @@ -32,6 +32,9 @@ func (lrw *loggingResponseWriter) Header() http.Header { func (lrw *loggingResponseWriter) Write(bytes []byte) (int, error) { n, err := lrw.downstreamResponseWriter.Write(bytes) + if f, ok := lrw.downstreamResponseWriter.(http.Flusher); ok { + f.Flush() + } lrw.bytesWritten += n