diff --git a/CryptoExchange.Net/Objects/ExchangeOptions.cs b/CryptoExchange.Net/Objects/ExchangeOptions.cs index 6a2d796..44564fe 100644 --- a/CryptoExchange.Net/Objects/ExchangeOptions.cs +++ b/CryptoExchange.Net/Objects/ExchangeOptions.cs @@ -57,6 +57,6 @@ namespace CryptoExchange.Net.Objects /// /// Time to wait between reconnect attempts /// - public TimeSpan ReconnectInterval { get; set; } = TimeSpan.FromSeconds(2); + public TimeSpan ReconnectInterval { get; set; } = TimeSpan.FromSeconds(5); } } diff --git a/CryptoExchange.Net/SocketClient.cs b/CryptoExchange.Net/SocketClient.cs index 645b47d..4d09e5f 100644 --- a/CryptoExchange.Net/SocketClient.cs +++ b/CryptoExchange.Net/SocketClient.cs @@ -114,7 +114,9 @@ namespace CryptoExchange.Net lock(sockets) subscription = sockets.Single(s => s.Socket == socket); - SocketReconnected(subscription, DateTime.UtcNow - socket.DisconnectTime.Value); + if (!SocketReconnect(subscription, DateTime.UtcNow - socket.DisconnectTime.Value)) + socket.Close().Wait(); // Close so we end up reconnecting again + return; }); } else diff --git a/CryptoExchange.Net/Sockets/BaseSocket.cs b/CryptoExchange.Net/Sockets/BaseSocket.cs index 1c755e9..6bbd4ea 100644 --- a/CryptoExchange.Net/Sockets/BaseSocket.cs +++ b/CryptoExchange.Net/Sockets/BaseSocket.cs @@ -222,7 +222,7 @@ namespace CryptoExchange.Net.Sockets lock (socketLock) { if (socket != null) - log.Write(LogVerbosity.Debug, $"Socket {Id} sisposing websocket"); + log.Write(LogVerbosity.Debug, $"Socket {Id} disposing websocket"); socket?.Dispose(); socket = null;