Fix sending next queued websocket notification.
This commit is contained in:
parent
b9fd527d33
commit
49b15625b9
1 changed files with 2 additions and 0 deletions
|
@ -1199,6 +1199,8 @@ out:
|
||||||
if len(q) == 0 {
|
if len(q) == 0 {
|
||||||
dequeue = nil
|
dequeue = nil
|
||||||
skipQueue = s.dequeueNotification
|
skipQueue = s.dequeueNotification
|
||||||
|
} else {
|
||||||
|
next = q[0]
|
||||||
}
|
}
|
||||||
|
|
||||||
case <-s.quit:
|
case <-s.quit:
|
||||||
|
|
Loading…
Reference in a new issue