Fixed unhandled messages after unsubscribing

2026-08-11 16:32:57 +00:00 · 2021-04-27 15:34:33 +02:00
parent 2720a03290
commit 93a64b2b1d
1 changed files with 4 additions and 5 deletions
@@ -424,14 +424,13 @@ namespace CryptoExchange.Net.Sockets

            var shouldCloseWrapper = false;
            lock (handlersLock)
-            {
-                handlers.Remove(subscription);
-                if (handlers.Count(r => r.UserSubscription) == 0)
-                    shouldCloseWrapper = true;
-            }
+                shouldCloseWrapper = handlers.Count(r => r.UserSubscription && subscription != r) == 0;

            if (shouldCloseWrapper)
                await Close().ConfigureAwait(false);
+
+            lock (handlersLock)            
+                handlers.Remove(subscription);            
        }
    }