From 4c95b202519a2ebd2546fb508a9244cc4ba946b0 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Zolt=C3=A1n=20Papp?= Date: Tue, 28 Jul 2026 16:30:15 +0200 Subject: [PATCH] [client] Drain buffered tick when coalesce window expires --- client/server/status_stream.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/client/server/status_stream.go b/client/server/status_stream.go index ac5d5f8fb..a53c39d2a 100644 --- a/client/server/status_stream.go +++ b/client/server/status_stream.go @@ -73,6 +73,14 @@ func collectStatusBurst(ctx context.Context, ch <-chan struct{}) (pending, open } pending = true case <-timer.C: + select { + case _, ok := <-ch: + if !ok { + return pending, false + } + pending = true + default: + } return pending, true case <-ctx.Done(): return false, false