We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9d6b793 commit 5daa583Copy full SHA for 5daa583
server/sse.go
@@ -281,20 +281,15 @@ func (s *SSEServer) Start(addr string) error {
281
// Shutdown gracefully stops the SSE server, closing all active sessions
282
// and shutting down the HTTP server.
283
func (s *SSEServer) Shutdown(ctx context.Context) error {
284
- s.mu.RLock()
285
- srv := s.srv
286
- s.mu.RUnlock()
287
-
288
- if srv != nil {
+ if s.srv != nil {
289
s.sessions.Range(func(key, value interface{}) bool {
290
if session, ok := value.(*sseSession); ok {
291
close(session.done)
292
}
293
s.sessions.Delete(key)
294
return true
295
})
296
297
- return srv.Shutdown(ctx)
+ return s.srv.Shutdown(ctx)
298
299
return nil
300
0 commit comments