Fix for concurrency exception

2026-08-11 16:32:57 +00:00 · 2023-09-18 20:02:01 +02:00
parent 4fd7e44015
commit 2443f576ac
1 changed files with 4 additions and 1 deletions
@@ -291,7 +291,10 @@ namespace CryptoExchange.Net.Sockets
        /// <param name="requestId">Id of the request sent</param>
        protected virtual void HandleRequestSent(int requestId)
        {
-            var pendingRequest = _pendingRequests.SingleOrDefault(p => p.Id == requestId);
+            PendingRequest pendingRequest;
+            lock (_pendingRequests)
+                pendingRequest = _pendingRequests.SingleOrDefault(p => p.Id == requestId);
+
            if (pendingRequest == null)
            {
                _logger.Log(LogLevel.Debug, $"Socket {SocketId} - msg {requestId} - message sent, but not pending");