From 2478e4c7c713fd652ee6328e0e6d9f109b28682f Mon Sep 17 00:00:00 2001
From: Jan Korf <jankorf91@gmail.com>
Date: Thu, 22 Nov 2018 13:18:39 +0100
Subject: [PATCH] updated resubscribing

---
 CryptoExchange.Net/Objects/ExchangeOptions.cs | 2 +-
 CryptoExchange.Net/SocketClient.cs            | 4 +++-
 CryptoExchange.Net/Sockets/BaseSocket.cs      | 2 +-
 3 files changed, 5 insertions(+), 3 deletions(-)

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
         /// <summary>
         /// Time to wait between reconnect attempts
         /// </summary>
-        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;