flywithu/CryptoExchange.Net
1
0
Fork 0
mirror of https://github.com/JKorf/CryptoExchange.Net synced 2026-02-16 14:13:46 +00:00
Code Issues Releases Wiki Activity

Made Interval property of Kline tracker public

Browse Source
This commit is contained in:
Jkorf 2026-01-28 10:31:44 +01:00
parent 913bdaa855
commit eaeba6f27e
2 changed files with 12 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
CryptoExchange.Net/Trackers/Klines/IKlineTracker.cs
View File

@ -55,6 +55,11 @@ namespace CryptoExchange.Net.Trackers.Klines
/// </summary> /// </summary>
SharedKline? Last { get; } SharedKline? Last { get; }
/// <summary>
/// The kline interval
/// </summary>
public SharedKlineInterval Interval { get; }
/// <summary> /// <summary>
/// Event for when a new kline is added /// Event for when a new kline is added
/// </summary> /// </summary>

14
CryptoExchange.Net/Trackers/Klines/KlineTracker.cs
View File

@ -45,10 +45,6 @@ namespace CryptoExchange.Net.Trackers.Klines
/// </summary> /// </summary>
protected bool _changed = false; protected bool _changed = false;
/// <summary> /// <summary>
/// The kline interval
/// </summary>
protected readonly SharedKlineInterval _interval;
/// <summary>
/// Whether the snapshot has been set /// Whether the snapshot has been set
/// </summary> /// </summary>
protected bool _snapshotSet; protected bool _snapshotSet;
@ -66,6 +62,10 @@ namespace CryptoExchange.Net.Trackers.Klines
/// </summary> /// </summary>
protected DateTime? _firstTimestamp; protected DateTime? _firstTimestamp;
/// <summary>
/// The kline interval
/// </summary>
public SharedKlineInterval Interval { get; }
/// <inheritdoc/> /// <inheritdoc/>
public SyncStatus Status public SyncStatus Status
{ {
@ -165,7 +165,7 @@ namespace CryptoExchange.Net.Trackers.Klines
Exchange = restClient.Exchange; Exchange = restClient.Exchange;
Limit = limit; Limit = limit;
Period = period; Period = period;
_interval = interval; Interval = interval;
_socketClient = socketClient; _socketClient = socketClient;
_restClient = restClient; _restClient = restClient;
} }
@ -180,7 +180,7 @@ namespace CryptoExchange.Net.Trackers.Klines
Status = SyncStatus.Syncing; Status = SyncStatus.Syncing;
_logger.KlineTrackerStarting(SymbolName); _logger.KlineTrackerStarting(SymbolName);
var subResult = await _socketClient.SubscribeToKlineUpdatesAsync(new SubscribeKlineRequest(Symbol, _interval), var subResult = await _socketClient.SubscribeToKlineUpdatesAsync(new SubscribeKlineRequest(Symbol, Interval),
update => update =>
{ {
AddOrUpdate(update.Data); AddOrUpdate(update.Data);
@ -237,7 +237,7 @@ namespace CryptoExchange.Net.Trackers.Klines
var limit = Math.Min(_restClient.GetKlinesOptions.MaxLimit, Limit ?? 100); 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<SharedKline>(); var data = new List<SharedKline>();
await foreach (var result in ExchangeHelpers.ExecutePages(_restClient.GetKlinesAsync, request).ConfigureAwait(false)) await foreach (var result in ExchangeHelpers.ExecutePages(_restClient.GetKlinesAsync, request).ConfigureAwait(false))
{ {