mirror of
https://github.com/JKorf/CryptoExchange.Net
synced 2025-09-03 06:01:40 +00:00
Fixed timing issue in query response processing
This commit is contained in:
parent
4a9058fc1c
commit
40977ebdbe
@ -188,10 +188,7 @@ namespace CryptoExchange.Net.Sockets
|
|||||||
|
|
||||||
CurrentResponses++;
|
CurrentResponses++;
|
||||||
if (CurrentResponses == RequiredResponses)
|
if (CurrentResponses == RequiredResponses)
|
||||||
{
|
|
||||||
Completed = true;
|
|
||||||
Response = message.Data;
|
Response = message.Data;
|
||||||
}
|
|
||||||
|
|
||||||
if (Result?.Success != false)
|
if (Result?.Success != false)
|
||||||
// If an error result is already set don't override that
|
// If an error result is already set don't override that
|
||||||
@ -199,6 +196,7 @@ namespace CryptoExchange.Net.Sockets
|
|||||||
|
|
||||||
if (CurrentResponses == RequiredResponses)
|
if (CurrentResponses == RequiredResponses)
|
||||||
{
|
{
|
||||||
|
Completed = true;
|
||||||
_event.Set();
|
_event.Set();
|
||||||
if (ContinueAwaiter != null)
|
if (ContinueAwaiter != null)
|
||||||
await ContinueAwaiter.WaitAsync().ConfigureAwait(false);
|
await ContinueAwaiter.WaitAsync().ConfigureAwait(false);
|
||||||
|
Loading…
x
Reference in New Issue
Block a user