From 78e4c382645dda92748ec741523b03a190a34ae9 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Miroslav=20=C5=A0ediv=C3=BD?= Date: Tue, 26 Oct 2021 21:07:57 +0200 Subject: [PATCH] lastEmpty session cursors. --- internal/websocket/manager.go | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/internal/websocket/manager.go b/internal/websocket/manager.go index 9295e253..10ff58f9 100644 --- a/internal/websocket/manager.go +++ b/internal/websocket/manager.go @@ -139,6 +139,8 @@ func (manager *WebSocketManagerCtx) Start() { ticker := time.NewTicker(500 * time.Millisecond) defer ticker.Stop() + lastEmpty := false + for { select { case <-manager.shutdown: @@ -146,7 +148,13 @@ func (manager *WebSocketManagerCtx) Start() { case <-ticker.C: cursorsMap := manager.sessions.PopCursors() if len(cursorsMap) == 0 { - continue + if lastEmpty { + continue + } + + lastEmpty = true + } else { + lastEmpty = false } cursors := []message.SessionCursor{}