From 7c67a014f513c3e36bb051d930deb129982edcfa Mon Sep 17 00:00:00 2001 From: Jkorf Date: Tue, 10 Feb 2026 14:31:42 +0100 Subject: [PATCH] Added check for subscribe queries with TimeoutBehavior.Success to complete when subscription has received update --- CryptoExchange.Net/Sockets/Default/Subscription.cs | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/CryptoExchange.Net/Sockets/Default/Subscription.cs b/CryptoExchange.Net/Sockets/Default/Subscription.cs index 5ef3126..fd460e6 100644 --- a/CryptoExchange.Net/Sockets/Default/Subscription.cs +++ b/CryptoExchange.Net/Sockets/Default/Subscription.cs @@ -174,6 +174,14 @@ namespace CryptoExchange.Net.Sockets.Default { ConnectionInvocations++; TotalInvocations++; + if (SubscriptionQuery != null && !SubscriptionQuery.Completed && SubscriptionQuery.TimeoutBehavior == TimeoutBehavior.Succeed) + { + // The subscription query is one where it is successful if there is no error returned + // Since we've received a data update for the subscription we can assume the subscribe query was successful + // Call timeout to complete + SubscriptionQuery.Timeout(); + } + return route.Handle(connection, receiveTime, originalData, data); }