Skip to content

Commit 103410e

Browse files
Update server/sse.go
Co-authored-by: coderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com>
1 parent 9faca53 commit 103410e

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

server/sse.go

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -283,7 +283,12 @@ func (s *SSEServer) handleSSE(w http.ResponseWriter, r *http.Request) {
283283
for {
284284
select {
285285
case <-ticker.C:
286-
session.eventQueue <- fmt.Sprintf(":ping - %s\n\n", time.Now().Format(time.RFC3339))
286+
select {
287+
case session.eventQueue <- fmt.Sprintf(":ping - %s\n\n", time.Now().Format(time.RFC3339)):
288+
// Ping sent successfully
289+
default:
290+
log.Printf("Keep-alive ping dropped: event queue is full")
291+
}
287292
case <-session.done:
288293
return
289294
case <-r.Context().Done():

0 commit comments

Comments
 (0)