diff --git a/CryptoExchange.Net/Sockets/CryptoExchangeWebSocketClient.cs b/CryptoExchange.Net/Sockets/CryptoExchangeWebSocketClient.cs index 75617f2..a2c5707 100644 --- a/CryptoExchange.Net/Sockets/CryptoExchangeWebSocketClient.cs +++ b/CryptoExchange.Net/Sockets/CryptoExchangeWebSocketClient.cs @@ -31,6 +31,7 @@ namespace CryptoExchange.Net.Sockets private readonly IDictionary cookies; private readonly IDictionary headers; private CancellationTokenSource _ctsSource; + private ApiProxy _proxy; private readonly List _outgoingMessages; private DateTime _lastReceivedMessagesUpdate; @@ -209,6 +210,8 @@ namespace CryptoExchange.Net.Sockets /// public virtual void SetProxy(ApiProxy proxy) { + _proxy = proxy; + 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)); @@ -339,6 +342,7 @@ namespace CryptoExchange.Net.Sockets while (_sendBuffer.TryDequeue(out _)) { } // Clear send buffer _socket = CreateSocket(); + SetProxy(_proxy); _closed = false; }