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

Fixed proxy setting not used on reconnecting socket

Browse Source
This commit is contained in:
JKorf 2022-06-12 15:26:11 +02:00
parent d451c18821
commit 2040b1c175
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -31,6 +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 readonly List<DateTime> _outgoingMessages; private readonly List<DateTime> _outgoingMessages;
private DateTime _lastReceivedMessagesUpdate; private DateTime _lastReceivedMessagesUpdate;
@ -209,6 +210,8 @@ namespace CryptoExchange.Net.Sockets
/// <inheritdoc /> /// <inheritdoc />
public virtual void SetProxy(ApiProxy proxy) public virtual void SetProxy(ApiProxy proxy)
{ {
_proxy = proxy;
if (!Uri.TryCreate($"{proxy.Host}:{proxy.Port}", UriKind.Absolute, out var uri)) if (!Uri.TryCreate($"{proxy.Host}:{proxy.Port}", UriKind.Absolute, out var uri))
throw new ArgumentException("Proxy settings invalid, {proxy.Host}:{proxy.Port} not a valid URI", nameof(proxy)); throw new ArgumentException("Proxy settings invalid, {proxy.Host}:{proxy.Port} not a valid URI", nameof(proxy));
@ -339,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();
SetProxy(_proxy);
_closed = false; _closed = false;
} }