diff --git a/server/events/sse.go b/server/events/sse.go index b06f6f896..3c35fd8d7 100644 --- a/server/events/sse.go +++ b/server/events/sse.go @@ -159,7 +159,6 @@ func (b *broker) ServeHTTP(w http.ResponseWriter, r *http.Request) { } } log.Trace(ctx, "Client EventStream connection closed", "client", c.String()) - return } func (b *broker) subscribe(r *http.Request) client {