changes: Fixed crash on disconnect when there are more than one client connected.
This commit is contained in:
@@ -40,6 +40,7 @@ func Subscribe(ctx context.Context, keys []models.ChangeKey, wildcard bool) <-ch
|
|||||||
for i := range subList {
|
for i := range subList {
|
||||||
if subList[i] == sub {
|
if subList[i] == sub {
|
||||||
subList = append(subList[:i], subList[i+1:]...)
|
subList = append(subList[:i], subList[i+1:]...)
|
||||||
|
break
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
subMutex.Unlock()
|
subMutex.Unlock()
|
||||||
|
|||||||
Reference in New Issue
Block a user