From 329f849a7255bac35d771cc920a001da940f1661 Mon Sep 17 00:00:00 2001 From: Grail Finder Date: Fri, 11 Jul 2025 17:55:21 +0300 Subject: [PATCH] Fix: freezes --- broker/sse.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/broker/sse.go b/broker/sse.go index 6a49de9..1946bb4 100644 --- a/broker/sse.go +++ b/broker/sse.go @@ -59,7 +59,7 @@ func (broker *Broker) ServeHTTP(w http.ResponseWriter, r *http.Request) { } w.Header().Set("Access-Control-Allow-Origin", origin) w.Header().Set("Access-Control-Allow-Credentials", "true") - messageChan := make(NotifierChan) + messageChan := make(NotifierChan, 10) // Buffered channel broker.newClients <- messageChan defer func() { broker.closingClients <- messageChan }() ctx := r.Context() @@ -81,7 +81,7 @@ func (broker *Broker) ServeHTTP(w http.ResponseWriter, r *http.Request) { w.(http.Flusher).Flush() case <-heartbeat.C: // Send SSE heartbeat comment - if _, err := w.Write([]byte(": heartbeat\n\n")); err != nil { + if _, err := fmt.Fprint(w, ":\n\n"); err != nil { return // Client disconnected } w.(http.Flusher).Flush()