mirror of
https://github.com/JKorf/CryptoExchange.Net
synced 2026-02-16 14:13:46 +00:00
Added some code comments
This commit is contained in:
parent
5e083811df
commit
b94085a27a
@ -1103,6 +1103,12 @@ namespace CryptoExchange.Net.Sockets.Default
|
|||||||
return CallResult.SuccessResult;
|
return CallResult.SuccessResult;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Try to subscribe a new subscription by sending the subscribe query and wait for the result as needed
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="subscription">The subscription</param>
|
||||||
|
/// <param name="newSubscription">Whether this is a new subscription, or an existing subscription (resubscribing on reconnected socket)</param>
|
||||||
|
/// <param name="subCancelToken">Cancellation token</param>
|
||||||
protected internal async Task<CallResult> TrySubscribeAsync(Subscription subscription, bool newSubscription, CancellationToken subCancelToken)
|
protected internal async Task<CallResult> TrySubscribeAsync(Subscription subscription, bool newSubscription, CancellationToken subCancelToken)
|
||||||
{
|
{
|
||||||
subscription.ConnectionInvocations = 0;
|
subscription.ConnectionInvocations = 0;
|
||||||
|
|||||||
@ -7,6 +7,9 @@ using System.Text;
|
|||||||
|
|
||||||
namespace CryptoExchange.Net.Trackers.UserData.Objects
|
namespace CryptoExchange.Net.Trackers.UserData.Objects
|
||||||
{
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// Tracker for symbols used in UserDataTracker
|
||||||
|
/// </summary>
|
||||||
public class UserDataSymbolTracker
|
public class UserDataSymbolTracker
|
||||||
{
|
{
|
||||||
private readonly ILogger _logger;
|
private readonly ILogger _logger;
|
||||||
@ -14,6 +17,9 @@ namespace CryptoExchange.Net.Trackers.UserData.Objects
|
|||||||
private readonly bool _onlyTrackProvidedSymbols;
|
private readonly bool _onlyTrackProvidedSymbols;
|
||||||
private readonly object _symbolLock = new object();
|
private readonly object _symbolLock = new object();
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// ctor
|
||||||
|
/// </summary>
|
||||||
public UserDataSymbolTracker(ILogger logger, UserDataTrackerConfig config)
|
public UserDataSymbolTracker(ILogger logger, UserDataTrackerConfig config)
|
||||||
{
|
{
|
||||||
_logger = logger;
|
_logger = logger;
|
||||||
@ -21,12 +27,19 @@ namespace CryptoExchange.Net.Trackers.UserData.Objects
|
|||||||
_onlyTrackProvidedSymbols = config.OnlyTrackProvidedSymbols;
|
_onlyTrackProvidedSymbols = config.OnlyTrackProvidedSymbols;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Get currently tracked symbols
|
||||||
|
/// </summary>
|
||||||
|
/// <returns></returns>
|
||||||
public IEnumerable<SharedSymbol> GetTrackedSymbols()
|
public IEnumerable<SharedSymbol> GetTrackedSymbols()
|
||||||
{
|
{
|
||||||
lock (_symbolLock)
|
lock (_symbolLock)
|
||||||
return _trackedSymbols.ToList();
|
return _trackedSymbols.ToList();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Check whether a symbol is in the tracked symbols list and should be processed
|
||||||
|
/// </summary>
|
||||||
public bool ShouldProcess(SharedSymbol symbol)
|
public bool ShouldProcess(SharedSymbol symbol)
|
||||||
{
|
{
|
||||||
if (!_onlyTrackProvidedSymbols)
|
if (!_onlyTrackProvidedSymbols)
|
||||||
|
|||||||
@ -177,7 +177,7 @@ namespace CryptoExchange.Net.Trackers.UserData
|
|||||||
SymbolTracker.RemoveTrackedSymbol(symbol);
|
SymbolTracker.RemoveTrackedSymbol(symbol);
|
||||||
|
|
||||||
((FuturesOrderTracker)Orders).ClearDataForSymbol(symbol);
|
((FuturesOrderTracker)Orders).ClearDataForSymbol(symbol);
|
||||||
((FuturesUserTradeTracker)Trades).ClearDataForSymbol(symbol);
|
((FuturesUserTradeTracker?)Trades)?.ClearDataForSymbol(symbol);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@ -150,7 +150,7 @@ namespace CryptoExchange.Net.Trackers.UserData
|
|||||||
SymbolTracker.RemoveTrackedSymbol(symbol);
|
SymbolTracker.RemoveTrackedSymbol(symbol);
|
||||||
|
|
||||||
((SpotOrderTracker)Orders).ClearDataForSymbol(symbol);
|
((SpotOrderTracker)Orders).ClearDataForSymbol(symbol);
|
||||||
((SpotUserTradeTracker)Trades).ClearDataForSymbol(symbol);
|
((SpotUserTradeTracker?)Trades)?.ClearDataForSymbol(symbol);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user