Fixed cancellation token not getting passed in shared ticker subscrip…

…tions
JKorf · Oct 7, 2024 · feb60c9 · feb60c9
1 parent 7dec21d
commit feb60c9
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/Kucoin.Net/Clients/FuturesApi/KucoinSocketClientFuturesApiShared.cs b/Kucoin.Net/Clients/FuturesApi/KucoinSocketClientFuturesApiShared.cs
@@ -28,7 +28,7 @@ async Task<ExchangeResult<UpdateSubscription>> ITickerSocketClient.SubscribeToTi
                 return new ExchangeResult<UpdateSubscription>(Exchange, validationError);
 
             var symbol = request.Symbol.GetSymbol(FormatSymbol);
-            var result = await SubscribeTo24HourSnapshotUpdatesAsync(symbol, update => handler(update.AsExchangeEvent(Exchange, new SharedSpotTicker(symbol, update.Data.LastPrice, null, null, update.Data.Volume, update.Data.PriceChangePercentage * 100)))).ConfigureAwait(false);
+            var result = await SubscribeTo24HourSnapshotUpdatesAsync(symbol, update => handler(update.AsExchangeEvent(Exchange, new SharedSpotTicker(symbol, update.Data.LastPrice, null, null, update.Data.Volume, update.Data.PriceChangePercentage * 100))), ct).ConfigureAwait(false);
 
             return new ExchangeResult<UpdateSubscription>(Exchange, result);
         }

diff --git a/Kucoin.Net/Clients/SpotApi/KucoinSocketClientSpotApiShared.cs b/Kucoin.Net/Clients/SpotApi/KucoinSocketClientSpotApiShared.cs
@@ -28,7 +28,7 @@ async Task<ExchangeResult<UpdateSubscription>> ITickerSocketClient.SubscribeToTi
                 return new ExchangeResult<UpdateSubscription>(Exchange, validationError);
 
             var symbol = request.Symbol.GetSymbol(FormatSymbol);
-            var result = await SubscribeToSnapshotUpdatesAsync(symbol, update => handler(update.AsExchangeEvent(Exchange, new SharedSpotTicker(symbol, update.Data.LastPrice ?? 0, update.Data.HighPrice ?? 0, update.Data.LowPrice ?? 0, update.Data.Volume, update.Data.ChangePercentage * 100)))).ConfigureAwait(false);
+            var result = await SubscribeToSnapshotUpdatesAsync(symbol, update => handler(update.AsExchangeEvent(Exchange, new SharedSpotTicker(symbol, update.Data.LastPrice ?? 0, update.Data.HighPrice ?? 0, update.Data.LowPrice ?? 0, update.Data.Volume, update.Data.ChangePercentage * 100))), ct).ConfigureAwait(false);
 
             return new ExchangeResult<UpdateSubscription>(Exchange, result);
         }