diff --git a/models/changes/subscribe.go b/models/changes/subscribe.go index 489d693..b5b9cd6 100644 --- a/models/changes/subscribe.go +++ b/models/changes/subscribe.go @@ -40,6 +40,7 @@ func Subscribe(ctx context.Context, keys []models.ChangeKey, wildcard bool) <-ch for i := range subList { if subList[i] == sub { subList = append(subList[:i], subList[i+1:]...) + break } } subMutex.Unlock()