flywithu/CryptoExchange.Net
1
0
Fork 0
mirror of https://github.com/JKorf/CryptoExchange.Net synced 2025-06-09 00:46:19 +00:00
Code Issues Releases Wiki Activity

Merge pull request #72 from EricGarnier/master

Browse Source 
Fix for issue #71
This commit is contained in:
Jan Korf 2020-12-21 13:06:28 +01:00 committed by GitHub
commit 76a0f6899f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
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

@ -148,11 +148,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;
@ -233,7 +245,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);
} }