From eaeba6f27efea5f1ba4afc94bc0d05ffa6543ad9 Mon Sep 17 00:00:00 2001 From: Jkorf Date: Wed, 28 Jan 2026 10:31:44 +0100 Subject: [PATCH] Made Interval property of Kline tracker public --- .../Trackers/Klines/IKlineTracker.cs | 5 +++++ CryptoExchange.Net/Trackers/Klines/KlineTracker.cs | 14 +++++++------- 2 files changed, 12 insertions(+), 7 deletions(-) diff --git a/CryptoExchange.Net/Trackers/Klines/IKlineTracker.cs b/CryptoExchange.Net/Trackers/Klines/IKlineTracker.cs index c83b54a..f18526b 100644 --- a/CryptoExchange.Net/Trackers/Klines/IKlineTracker.cs +++ b/CryptoExchange.Net/Trackers/Klines/IKlineTracker.cs @@ -55,6 +55,11 @@ namespace CryptoExchange.Net.Trackers.Klines /// SharedKline? Last { get; } + /// + /// The kline interval + /// + public SharedKlineInterval Interval { get; } + /// /// Event for when a new kline is added /// diff --git a/CryptoExchange.Net/Trackers/Klines/KlineTracker.cs b/CryptoExchange.Net/Trackers/Klines/KlineTracker.cs index 3c475b5..5083474 100644 --- a/CryptoExchange.Net/Trackers/Klines/KlineTracker.cs +++ b/CryptoExchange.Net/Trackers/Klines/KlineTracker.cs @@ -45,10 +45,6 @@ namespace CryptoExchange.Net.Trackers.Klines /// protected bool _changed = false; /// - /// The kline interval - /// - protected readonly SharedKlineInterval _interval; - /// /// Whether the snapshot has been set /// protected bool _snapshotSet; @@ -66,6 +62,10 @@ namespace CryptoExchange.Net.Trackers.Klines /// protected DateTime? _firstTimestamp; + /// + /// The kline interval + /// + public SharedKlineInterval Interval { get; } /// public SyncStatus Status { @@ -165,7 +165,7 @@ namespace CryptoExchange.Net.Trackers.Klines Exchange = restClient.Exchange; Limit = limit; Period = period; - _interval = interval; + Interval = interval; _socketClient = socketClient; _restClient = restClient; } @@ -180,7 +180,7 @@ namespace CryptoExchange.Net.Trackers.Klines Status = SyncStatus.Syncing; _logger.KlineTrackerStarting(SymbolName); - var subResult = await _socketClient.SubscribeToKlineUpdatesAsync(new SubscribeKlineRequest(Symbol, _interval), + var subResult = await _socketClient.SubscribeToKlineUpdatesAsync(new SubscribeKlineRequest(Symbol, Interval), update => { AddOrUpdate(update.Data); @@ -237,7 +237,7 @@ namespace CryptoExchange.Net.Trackers.Klines var limit = Math.Min(_restClient.GetKlinesOptions.MaxLimit, Limit ?? 100); - var request = new GetKlinesRequest(Symbol, _interval, startTime, DateTime.UtcNow, limit: limit); + var request = new GetKlinesRequest(Symbol, Interval, startTime, DateTime.UtcNow, limit: limit); var data = new List(); await foreach (var result in ExchangeHelpers.ExecutePages(_restClient.GetKlinesAsync, request).ConfigureAwait(false)) {