vndangkhoa/neko
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

cursors add currentEmpty.

Browse source
This commit is contained in:
Miroslav Šedivý 2021-11-07 21:23:23 +01:00
parent 6b77f54b8c
commit 15cb4300a5
1 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
internal/websocket/manager.go
View file

@ -309,7 +309,8 @@ func (manager *WebSocketManagerCtx) inactiveCursors() {
ticker := time.NewTicker(inactiveCursorsPeriod) ticker := time.NewTicker(inactiveCursorsPeriod)
defer ticker.Stop() defer ticker.Stop()
lastEmpty := false var currentEmpty bool
var lastEmpty = false
for { for {
select { select {
@ -319,11 +320,11 @@ func (manager *WebSocketManagerCtx) inactiveCursors() {
case <-ticker.C: case <-ticker.C:
cursorsMap := manager.sessions.PopCursors() cursorsMap := manager.sessions.PopCursors()
length := len(cursorsMap) currentEmpty = len(cursorsMap) == 0
if length == 0 && lastEmpty { if currentEmpty && lastEmpty {
continue continue
} }
lastEmpty = length == 0 lastEmpty = currentEmpty
cursors := []message.SessionCursor{} cursors := []message.SessionCursor{}
for session, cursor := range cursorsMap { for session, cursor := range cursorsMap {