flywithu/CryptoExchange.Net
1
0
Fork 0
mirror of https://github.com/JKorf/CryptoExchange.Net synced 2025-06-08 16:36:15 +00:00
Code Issues Releases Wiki Activity

Merge branch 'master' of https://github.com/JKorf/CryptoExchange.Net

Browse Source
This commit is contained in:
Jkorf 2020-12-21 14:11:39 +01:00
commit 24cc7a3c77
1 changed files with 18 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
CryptoExchange.Net/Sockets/SocketConnection.cs
View File

@ -152,11 +152,23 @@ namespace CryptoExchange.Net.Sockets
} }
var handledResponse = false; var handledResponse = false;
foreach (var pendingRequest in pendingRequests.ToList()) PendingRequest[] requests;
lock(pendingRequests)
{
requests = pendingRequests.ToArray();
}
foreach (var pendingRequest in requests)
{ {
if (pendingRequest.Check(tokenData)) if (pendingRequest.Check(tokenData))
{
lock (pendingRequests)
{ {
pendingRequests.Remove(pendingRequest); pendingRequests.Remove(pendingRequest);
}
if (pendingRequest.Result == null)
{
continue; // A previous timeout.
}
if (!socketClient.ContinueOnQueryResponse) if (!socketClient.ContinueOnQueryResponse)
return; return;
handledResponse = true; handledResponse = true;
@ -238,7 +250,10 @@ namespace CryptoExchange.Net.Sockets
public virtual Task SendAndWait<T>(T obj, TimeSpan timeout, Func<JToken, bool> handler) public virtual Task SendAndWait<T>(T obj, TimeSpan timeout, Func<JToken, bool> handler)
{ {
var pending = new PendingRequest(handler, timeout); var pending = new PendingRequest(handler, timeout);
lock (pendingRequests)
{
pendingRequests.Add(pending); pendingRequests.Add(pending);
}
Send(obj); Send(obj);
return pending.Event.WaitOneAsync(timeout); return pending.Event.WaitOneAsync(timeout);
} }