Fix incorrect prefix unsubscribe (#144)

microsoft · Mar 27, 2024 · f7b6e08 · f7b6e08
1 parent 922c975
commit f7b6e08
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/libs/server/PubSub/SubscribeBroker.cs b/libs/server/PubSub/SubscribeBroker.cs
@@ -311,7 +311,7 @@ public unsafe void PUnsubscribe(byte* key, ServerSessionBase session)
                     {
                         if (subscriptionDict.Item2.TryGetValue(sid, out var _session))
                         {
-                            if (_session != session)
+                            if (_session == session)
                             {
                                 subscriptionDict.Item2.TryRemove(sid, out _);
                                 break;