Binance.TradeRobot.API/SDKAdapter/WebSockets/Market/BinanceSpotMarketWebSocketClient.cs

using Binance.Net.Clients;
using Binance.Net.Enums;
using System.Threading;

namespace SDKAdapter.WebSockets.Market
{
    public class BinanceSpotMarketWebSocketClient : SpotMarketWebSocketClient
    {
        private BinanceSocketClient client;
        private CancellationTokenSource cancellationTokenSource;

        public BinanceSpotMarketWebSocketClient(string symbol, NLog.ILogger logger) : base(symbol, logger)
        {
            client = new BinanceSocketClient();

        }

        public override void Start()
        {
            cancellationTokenSource = new CancellationTokenSource();
            client.SpotStreams.SubscribeToKlineUpdatesAsync(Symbol, KlineInterval.OneMinute, (e) =>
            {
                base.OnReceived(e.Data.Data.ClosePrice);
            }, cancellationTokenSource.Token);
            base.Start();
        }

        public override void Stop()
        {
            cancellationTokenSource.Cancel();
            client.SpotStreams.Dispose();
            base.Stop();
            cancellationTokenSource = null;
        }
    }
}