X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/70111d82653ca633d2397c74eb994a8a9d718e80..78eedab0a2feadc7877529ac4ce65ccaaf4db768:/sdk/go/httpserver/responsewriter.go

diff --git a/sdk/go/httpserver/responsewriter.go b/sdk/go/httpserver/responsewriter.go
index 3941c13c22..8dea759ccb 100644
--- a/sdk/go/httpserver/responsewriter.go
+++ b/sdk/go/httpserver/responsewriter.go
@@ -28,26 +28,36 @@ func WrapResponseWriter(orig http.ResponseWriter) ResponseWriter {
 	return &responseWriter{ResponseWriter: orig}
 }
 
-func (w responseWriter) WriteHeader(s int) {
+func (w *responseWriter) CloseNotify() <-chan bool {
+	if cn, ok := w.ResponseWriter.(http.CloseNotifier); ok {
+		return cn.CloseNotify()
+	}
+	return nil
+}
+
+func (w *responseWriter) WriteHeader(s int) {
 	w.wroteStatus = s
 	w.ResponseWriter.WriteHeader(s)
 }
 
-func (w responseWriter) Write(data []byte) (n int, err error) {
+func (w *responseWriter) Write(data []byte) (n int, err error) {
+	if w.wroteStatus == 0 {
+		w.WriteHeader(http.StatusOK)
+	}
 	n, err = w.ResponseWriter.Write(data)
 	w.wroteBodyBytes += n
 	w.err = err
 	return
 }
 
-func (w responseWriter) WroteStatus() int {
+func (w *responseWriter) WroteStatus() int {
 	return w.wroteStatus
 }
 
-func (w responseWriter) WroteBodyBytes() int {
+func (w *responseWriter) WroteBodyBytes() int {
 	return w.wroteBodyBytes
 }
 
-func (w responseWriter) Err() error {
+func (w *responseWriter) Err() error {
 	return w.err
 }