fix: increment _removes counter in RemoveBatch for accurate stats

2026-02-23 00:48:53 -05:00
parent 6afe11ad4d
commit 0347e8a28c
1 changed files with 4 additions and 1 deletions
--- 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);