1
0
mirror of https://github.com/JKorf/CryptoExchange.Net synced 2026-02-16 14:13:46 +00:00

Fixed HandleSubQueryResponse not getting called

This commit is contained in:
Jkorf 2026-01-21 11:16:57 +01:00
parent 76772e91ba
commit 21c8133292
2 changed files with 3 additions and 3 deletions

View File

@ -1114,6 +1114,7 @@ namespace CryptoExchange.Net.Sockets.Default
return; return;
await SendAndWaitQueryAsync(unsubscribeRequest).ConfigureAwait(false); await SendAndWaitQueryAsync(unsubscribeRequest).ConfigureAwait(false);
subscription.HandleUnsubQueryResponse(this, unsubscribeRequest.Response);
_logger.SubscriptionUnsubscribed(SocketId, subscription.Id); _logger.SubscriptionUnsubscribed(SocketId, subscription.Id);
} }
@ -1127,7 +1128,7 @@ namespace CryptoExchange.Net.Sockets.Default
return CallResult.SuccessResult; return CallResult.SuccessResult;
var result = await SendAndWaitQueryAsync(subQuery).ConfigureAwait(false); var result = await SendAndWaitQueryAsync(subQuery).ConfigureAwait(false);
subscription.HandleSubQueryResponse(this, subQuery.Response!); subscription.HandleSubQueryResponse(this, subQuery.Response);
return result; return result;
} }

View File

@ -149,8 +149,7 @@ namespace CryptoExchange.Net.Sockets.Default
/// <summary> /// <summary>
/// Handle an unsubscription query response /// Handle an unsubscription query response
/// </summary> /// </summary>
#warning ? public virtual void HandleUnsubQueryResponse(SocketConnection connection, object? message) { }
public virtual void HandleUnsubQueryResponse(SocketConnection connection, object message) { }
/// <summary> /// <summary>
/// Create a new unsubscription query /// Create a new unsubscription query