Skip to content

K
k3s
Unverified Commit 080d2a43 authored by Kubernetes Prow Robot's avatar Kubernetes Prow Robot Committed by GitHub
Browse files
Options

Merge pull request #72575 from liggitt/flush-streamer-headers

Flush headers before streaming logs
parents d3aa7b2c 93625f50
Hide whitespace changes
Inline Side-by-side
Showing with 4 additions and 0 deletions
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/responsewriters/writers.go
View file @ 080d2a43
...@@ -101,6 +101,10 @@ func StreamObject(statusCode int, gv schema.GroupVersion, s runtime.NegotiatedSe ...@@ -101,6 +101,10 @@ func StreamObject(statusCode int, gv schema.GroupVersion, s runtime.NegotiatedSe
} }
w.Header().Set("Content-Type", contentType) w.Header().Set("Content-Type", contentType)
w.WriteHeader(statusCode) w.WriteHeader(statusCode)
// Flush headers, if possible
if flusher, ok := w.(http.Flusher); ok {
flusher.Flush()
}
writer := w.(io.Writer) writer := w.(io.Writer)
if flush { if flush {
writer = flushwriter.Wrap(w) writer = flushwriter.Wrap(w)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment