From 8def7f32af6ec38fb997404b60fc048644a51b5e Mon Sep 17 00:00:00 2001 From: JKorf Date: Tue, 4 Mar 2025 19:45:06 +0100 Subject: [PATCH] Update UnsubscribeAll in socket client to also unsubscribe on a dedicated connection --- CryptoExchange.Net/Clients/SocketApiClient.cs | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/CryptoExchange.Net/Clients/SocketApiClient.cs b/CryptoExchange.Net/Clients/SocketApiClient.cs index f3b8e75..5098b7b 100644 --- a/CryptoExchange.Net/Clients/SocketApiClient.cs +++ b/CryptoExchange.Net/Clients/SocketApiClient.cs @@ -671,8 +671,11 @@ namespace CryptoExchange.Net.Clients var tasks = new List(); { var socketList = socketConnections.Values; - foreach (var connection in socketList.Where(s => !s.DedicatedRequestConnection.IsDedicatedRequestConnection)) - tasks.Add(connection.CloseAsync()); + foreach (var connection in socketList) + { + foreach(var subscription in connection.Subscriptions.Where(x => x.UserSubscription)) + tasks.Add(connection.CloseAsync(subscription)); + } } await Task.WhenAll(tasks.ToArray()).ConfigureAwait(false);