diff --git a/server/events/sse.go b/server/events/sse.go index 24c32a121..c6371ad5b 100644 --- a/server/events/sse.go +++ b/server/events/sse.go @@ -144,6 +144,7 @@ func (b *broker) subscribe(r *http.Request) client { address: r.RemoteAddr, userAgent: r.UserAgent(), channel: make(messageChan, 5), + done: make(chan struct{}), } // Signal the broker that we have a new client