Merge branch 'main' into issue-dedup-sourcing-cost
This commit is contained in:
@@ -16,9 +16,12 @@ func (s *Server) HandleEvents(w http.ResponseWriter, r *http.Request) {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
// Disable the write deadline for this long-lived connection.
|
// Disable read and write deadlines for this long-lived connection.
|
||||||
// The server's WriteTimeout (15s) would otherwise kill it.
|
// The server's ReadTimeout/WriteTimeout (15s) would otherwise kill it.
|
||||||
rc := http.NewResponseController(w)
|
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 {
|
if err := rc.SetWriteDeadline(time.Time{}); err != nil {
|
||||||
s.logger.Warn().Err(err).Msg("failed to disable write deadline for SSE")
|
s.logger.Warn().Err(err).Msg("failed to disable write deadline for SSE")
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user