Fixed semaphore exception when creating a new REST client while time sync is in progress on another client

CryptoExchange.Net/Clients/SocketApiClient.cs

@@ -802,7 +802,6 @@ namespace CryptoExchange.Net.Clients
             return new CallResult<HighPerfSocketConnection<TUpdateType>>(socketConnection);
         }
 
-
         /// <summary>
         /// Process an unhandled message
         /// </summary>
@@ -811,6 +810,14 @@ namespace CryptoExchange.Net.Clients
         {
         }
 
+        /// <summary>
+        /// Process an unhandled message
+        /// </summary>
+        /// <param name="connection">The socket connection</param>
+        /// <param name="typeIdentifier">The type as identified</param>
+        /// <param name="data">The data</param>
+        protected internal virtual bool HandleUnhandledMessage(SocketConnection connection, string typeIdentifier, ReadOnlySpan<byte> data) => false;
+
         /// <summary>
         /// Process connect rate limited
         /// </summary>

CryptoExchange.Net/Sockets/Default/SocketConnection.cs

@@ -571,8 +571,12 @@ namespace CryptoExchange.Net.Sockets.Default
 
             if (deserializationType == null)
             {
-                // No handler found for identifier either, can't process
-                _logger.LogWarning("Failed to determine message type for identifier {Identifier}. Data: {Message}", typeIdentifier, Encoding.UTF8.GetString(data.ToArray()));
+                if (!ApiClient.HandleUnhandledMessage(this, typeIdentifier, data))
+                {
+                    // No handler found for identifier either, can't process
+                    _logger.LogWarning("Failed to determine message type for identifier {Identifier}. Data: {Message}", typeIdentifier, Encoding.UTF8.GetString(data.ToArray()));
+                }
+                    
                 return;
             }
             

CryptoExchange.Net/TimeOffsetManager.cs

@@ -113,7 +113,8 @@ namespace CryptoExchange.Net
         /// <param name="api"></param>
         internal static void RegisterRestApi(string api)
         {
-            _lastRestDelays[api] = new RestTimeOffset();
+            if (!_lastRestDelays.ContainsKey(api))
+                _lastRestDelays.TryAdd(api, new RestTimeOffset());
         }
 
         /// <summary>