flywithu/CryptoExchange.Net
1
0
Fork 0
mirror of https://github.com/JKorf/CryptoExchange.Net synced 2025-06-08 00:16:27 +00:00
Code Issues Releases Wiki Activity

Cleanup

Browse Source
This commit is contained in:
JKorf 2022-06-12 15:35:35 +02:00
parent ca888d8e41
commit 2cf3c93e5e
5 changed files with 18 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
CryptoExchange.Net.UnitTests/TestImplementations/TestRestClient.cs
View File

@ -135,7 +135,7 @@ namespace CryptoExchange.Net.UnitTests.TestImplementations
throw new NotImplementedException(); throw new NotImplementedException();
} }
protected override TimeSyncInfo GetTimeSyncInfo() public override TimeSyncInfo GetTimeSyncInfo()
{ {
throw new NotImplementedException(); throw new NotImplementedException();
} }
@ -161,7 +161,7 @@ namespace CryptoExchange.Net.UnitTests.TestImplementations
throw new NotImplementedException(); throw new NotImplementedException();
} }
protected override TimeSyncInfo GetTimeSyncInfo() public override TimeSyncInfo GetTimeSyncInfo()
{ {
throw new NotImplementedException(); throw new NotImplementedException();
} }

2
CryptoExchange.Net/Clients/BaseSocketClient.cs
View File

@ -92,7 +92,9 @@ namespace CryptoExchange.Net
} }
} }
/// <inheritdoc />
public int CurrentConnections => socketConnections.Count; public int CurrentConnections => socketConnections.Count;
/// <inheritdoc />
public int CurrentSubscriptions public int CurrentSubscriptions
{ {
get get

10
CryptoExchange.Net/Interfaces/ISocketClient.cs
View File

@ -27,6 +27,16 @@ namespace CryptoExchange.Net.Interfaces
/// </summary> /// </summary>
public double IncomingKbps { get; } public double IncomingKbps { get; }
/// <summary>
/// The current amount of connections to the API from this client. A connection can have multiple subscriptions.
/// </summary>
public int CurrentConnections { get; }
/// <summary>
/// The current amount of subscriptions running from the client
/// </summary>
public int CurrentSubscriptions { get; }
/// <summary> /// <summary>
/// Unsubscribe from a stream using the subscription id received when starting the subscription /// Unsubscribe from a stream using the subscription id received when starting the subscription
/// </summary> /// </summary>

2
CryptoExchange.Net/Objects/Options.cs
View File

@ -14,7 +14,7 @@ namespace CryptoExchange.Net.Objects
/// </summary> /// </summary>
public class BaseOptions public class BaseOptions
{ {
internal event Action OnLoggingChanged; internal event Action? OnLoggingChanged;
private LogLevel _logLevel = LogLevel.Information; private LogLevel _logLevel = LogLevel.Information;
/// <summary> /// <summary>

3
CryptoExchange.Net/Sockets/CryptoExchangeWebSocketClient.cs
View File

@ -31,7 +31,7 @@ namespace CryptoExchange.Net.Sockets
private readonly IDictionary<string, string> cookies; private readonly IDictionary<string, string> cookies;
private readonly IDictionary<string, string> headers; private readonly IDictionary<string, string> headers;
private CancellationTokenSource _ctsSource; private CancellationTokenSource _ctsSource;
private ApiProxy _proxy; private ApiProxy? _proxy;
private readonly List<DateTime> _outgoingMessages; private readonly List<DateTime> _outgoingMessages;
private DateTime _lastReceivedMessagesUpdate; private DateTime _lastReceivedMessagesUpdate;
@ -342,6 +342,7 @@ namespace CryptoExchange.Net.Sockets
while (_sendBuffer.TryDequeue(out _)) { } // Clear send buffer while (_sendBuffer.TryDequeue(out _)) { } // Clear send buffer
_socket = CreateSocket(); _socket = CreateSocket();
if (_proxy != null)
SetProxy(_proxy); SetProxy(_proxy);
_closed = false; _closed = false;
} }