diff --git a/internal/api/sse_handler.go b/internal/api/sse_handler.go index 64da978..3734e85 100644 --- a/internal/api/sse_handler.go +++ b/internal/api/sse_handler.go @@ -16,9 +16,12 @@ func (s *Server) HandleEvents(w http.ResponseWriter, r *http.Request) { return } - // Disable the write deadline for this long-lived connection. - // The server's WriteTimeout (15s) would otherwise kill it. + // Disable read and write deadlines for this long-lived connection. + // The server's ReadTimeout/WriteTimeout (15s) would otherwise kill it. rc := http.NewResponseController(w) + if err := rc.SetReadDeadline(time.Time{}); err != nil { + s.logger.Warn().Err(err).Msg("failed to disable read deadline for SSE") + } if err := rc.SetWriteDeadline(time.Time{}); err != nil { s.logger.Warn().Err(err).Msg("failed to disable write deadline for SSE") }