For events, write header and flush earlier

2019-02-20 10:41:52 +01:00 · 2019-02-20 10:41:52 +01:00 · 0d24e58c88
commit 0d24e58c88
parent 83956b4d9f
1 changed files with 4 additions and 0 deletions
--- a/pkg/server/microsub.go
+++ b/pkg/server/microsub.go
@ -123,6 +123,10 @@ func (h *microsubHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 			w.Header().Set("Connection", "keep-alive")
 			w.Header().Set("Access-Control-Allow-Origin", "*")

+			w.WriteHeader(200)
+
+			flusher.Flush()
+
 			// Each connection registers its own message channel with the Broker's connections registry
 			messageChan := make(MessageChan)