From 1d338417e9a13457bf24c0d4b6412f6132e19966 Mon Sep 17 00:00:00 2001 From: Deluan Date: Sun, 13 Dec 2020 11:58:00 -0500 Subject: [PATCH] Make `done` channel buffered --- server/events/sse.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/events/sse.go b/server/events/sse.go index e18cb037..0ca841b3 100644 --- a/server/events/sse.go +++ b/server/events/sse.go @@ -140,7 +140,7 @@ func (b *broker) subscribe(r *http.Request) client { address: r.RemoteAddr, userAgent: r.UserAgent(), channel: make(messageChan, 5), - done: make(chan struct{}), + done: make(chan struct{}, 1), } // Signal the broker that we have a new client