From 716429f5091fdfb262b154cc531c3aa444649a95 Mon Sep 17 00:00:00 2001
From: Aaron Stannard <aaron@petabridge.com>
Date: Thu, 4 Sep 2025 11:04:20 -0500
Subject: [PATCH] fix `Replicator.ReceiveUnsubscribe` boolean logic

close #7804
---
 src/contrib/cluster/Akka.DistributedData/Replicator.cs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/contrib/cluster/Akka.DistributedData/Replicator.cs b/src/contrib/cluster/Akka.DistributedData/Replicator.cs
index 1fc40c852a6..c180ee03921 100644
--- 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);
         }