Added check for snapshot data in shared spot trades stream

JKorf · Oct 9, 2024 · b05e06e · b05e06e
1 parent 661e86a
commit b05e06e
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/CoinEx.Net/Clients/SpotApiV2/CoinExSocketClientSpotApiShared.cs b/CoinEx.Net/Clients/SpotApiV2/CoinExSocketClientSpotApiShared.cs
@@ -64,7 +64,13 @@ async Task<ExchangeResult<UpdateSubscription>> ITradeSocketClient.SubscribeToTra
                 return new ExchangeResult<UpdateSubscription>(Exchange, validationError);
 
             var symbol = request.Symbol.GetSymbol(FormatSymbol);
-            var result = await SubscribeToTradeUpdatesAsync(symbol, update => handler(update.AsExchangeEvent<IEnumerable<SharedTrade>>(Exchange, update.Data.Select(x => new SharedTrade(x.Quantity, x.Price, x.Timestamp)).ToArray())), ct).ConfigureAwait(false);
+            var result = await SubscribeToTradeUpdatesAsync(symbol, update =>
+            {
+                if (update.UpdateType == SocketUpdateType.Snapshot)
+                    return;
+
+                handler(update.AsExchangeEvent<IEnumerable<SharedTrade>>(Exchange, update.Data.Select(x => new SharedTrade(x.Quantity, x.Price, x.Timestamp)).ToArray()));
+            }, ct).ConfigureAwait(false);
 
             return new ExchangeResult<UpdateSubscription>(Exchange, result);
         }