diff --git a/src/NATS.Server/Subscriptions/SubList.cs b/src/NATS.Server/Subscriptions/SubList.cs index dd6b9ef..b7ca3c7 100644 --- a/src/NATS.Server/Subscriptions/SubList.cs +++ b/src/NATS.Server/Subscriptions/SubList.cs @@ -494,7 +494,10 @@ public sealed class SubList : IDisposable _cache = null; foreach (var sub in subs) - RemoveInternal(sub); + { + if (RemoveInternal(sub)) + _removes++; + } Interlocked.Increment(ref _generation);