fix Replicator.ReceiveUnsubscribe boolean logic (#7806)

Aaronontheweb · web-flow · commit 66f7f1e04260 · 2025-09-04T16:27:59.000Z
close #7804
diff --git a/src/contrib/cluster/Akka.DistributedData/Replicator.cs b/src/contrib/cluster/Akka.DistributedData/Replicator.cs
@@ -1240,7 +1240,7 @@ private void ReceiveUnsubscribe(IKey key, IActorRef subscriber)
             if (!HasSubscriber(subscriber))
                 Context.Unwatch(subscriber);
 
-            if (!_subscribers.ContainsKey(key.Id) || !_newSubscribers.ContainsKey(key.Id))
+            if (!_subscribers.ContainsKey(key.Id) && !_newSubscribers.ContainsKey(key.Id))
                 _subscriptionKeys = _subscriptionKeys.Remove(key.Id);
         }
 

Original file line number	Diff line number	Diff line change
`@@ -1240,7 +1240,7 @@ private void ReceiveUnsubscribe(IKey key, IActorRef subscriber)`
`1240`	`1240`	`if (!HasSubscriber(subscriber))`
`1241`	`1241`	`Context.Unwatch(subscriber);`
`1242`	`1242`
`1243`		`- if (!_subscribers.ContainsKey(key.Id) \|\| !_newSubscribers.ContainsKey(key.Id))`
	`1243`	`+ if (!_subscribers.ContainsKey(key.Id) && !_newSubscribers.ContainsKey(key.Id))`
`1244`	`1244`	`_subscriptionKeys = _subscriptionKeys.Remove(key.Id);`
`1245`	`1245`	`}`
`1246`	`1246`