mirror of
https://github.com/JKorf/CryptoExchange.Net
synced 2025-09-03 06:01:40 +00:00
Compare commits
2 Commits
dab9a21608
...
40977ebdbe
Author | SHA1 | Date | |
---|---|---|---|
|
40977ebdbe | ||
|
4a9058fc1c |
@ -47,7 +47,7 @@ namespace CryptoExchange.Net.Sockets
|
|||||||
/// </summary>
|
/// </summary>
|
||||||
public static MessageMatcher Create<T>(string value)
|
public static MessageMatcher Create<T>(string value)
|
||||||
{
|
{
|
||||||
return new MessageMatcher(new MessageHandlerLink<T>(MessageLinkType.Full, value, (con, msg) => CallResult.SuccessResult));
|
return new MessageMatcher(new MessageHandlerLink<T>(MessageLinkType.Full, value, (con, msg) => new CallResult<T>(default, msg.OriginalData, null)));
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
|
@ -187,11 +187,8 @@ namespace CryptoExchange.Net.Sockets
|
|||||||
return CallResult.SuccessResult;
|
return CallResult.SuccessResult;
|
||||||
|
|
||||||
CurrentResponses++;
|
CurrentResponses++;
|
||||||
if (CurrentResponses == RequiredResponses)
|
if (CurrentResponses == RequiredResponses)
|
||||||
{
|
Response = message.Data;
|
||||||
Completed = true;
|
|
||||||
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