From 8c063c4f0c87f8abd3d70026a9bd0674917a9445 Mon Sep 17 00:00:00 2001 From: Deluan Date: Mon, 21 Dec 2020 10:01:37 -0500 Subject: [PATCH] Removed unused variable --- server/events/sse.go | 12 ++++-------- 1 file changed, 4 insertions(+), 8 deletions(-) diff --git a/server/events/sse.go b/server/events/sse.go index 482a71269..0e96b043b 100644 --- a/server/events/sse.go +++ b/server/events/sse.go @@ -20,14 +20,15 @@ type Broker interface { SendMessage(event Event) } -var errWriteTimeOut = errors.New("write timeout") - const ( keepAliveFrequency = 15 * time.Second writeTimeOut = 5 * time.Second ) -var eventId uint32 +var ( + errWriteTimeOut = errors.New("write timeout") + eventId uint32 +) type ( message struct { @@ -43,7 +44,6 @@ type ( username string userAgent string channel messageChan - done chan struct{} } ) @@ -144,9 +144,6 @@ func (b *broker) ServeHTTP(w http.ResponseWriter, r *http.Request) { if err == errWriteTimeOut { return } - case <-c.done: - log.Trace(ctx, "Closing event stream connection", "client", c.String()) - return case <-ctx.Done(): log.Trace(ctx, "Client closed the connection", "client", c.String()) return @@ -163,7 +160,6 @@ func (b *broker) subscribe(r *http.Request) client { address: r.RemoteAddr, userAgent: r.UserAgent(), channel: make(messageChan, 5), - done: make(chan struct{}, 1), } // Signal the broker that we have a new client