From c98a0311aeabbe4cde99b680477d5b47fd82e45e Mon Sep 17 00:00:00 2001 From: Karn Date: Wed, 9 Apr 2025 20:34:01 +0530 Subject: [PATCH] fix sse shutdown --- server/sse.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/server/sse.go b/server/sse.go index 6e6a13fe7..f7081651f 100644 --- a/server/sse.go +++ b/server/sse.go @@ -269,6 +269,8 @@ func (s *SSEServer) handleSSE(w http.ResponseWriter, r *http.Request) { case <-r.Context().Done(): close(session.done) return + case <-session.done: + return } } }