Update JsonStreamController

sonvister · Mar 7, 2018 · da2967a · da2967a
1 parent a40c6b4
commit da2967a
Showing 1 changed file with 22 additions and 6 deletions.
diff --git a/src/Binance/Utility/JsonStreamController.cs b/src/Binance/Utility/JsonStreamController.cs
@@ -6,15 +6,31 @@
 
 namespace Binance.Utility
 {
-    public class JsonStreamController<TStream> : RetryTaskController, IJsonStreamController<TStream>
-        where TStream : IJsonStream
+    public class JsonStreamController : JsonStreamController<IJsonStream>, IJsonStreamController
     {
-        #region Private Constants
+        #region Public Constants
 
-        private readonly TimeSpan _watchdogTimerIntervalDefault = TimeSpan.FromHours(1);
+        public static readonly TimeSpan WatchdogTimerIntervalDefault = TimeSpan.FromHours(1);
 
-        #endregion Private Constants
+        #endregion Public Constants
+
+        #region Constructors
 
+        /// <summary>
+        /// Constructor.
+        /// </summary>
+        /// <param name="stream"></param>
+        /// <param name="logger"></param>
+        public JsonStreamController(IJsonStream stream, ILogger<JsonStreamController> logger = null)
+            : base(stream, logger)
+        { }
+
+        #endregion Constructors
+    }
+
+    public class JsonStreamController<TStream> : RetryTaskController, IJsonStreamController<TStream>
+        where TStream : IJsonStream
+    {
         #region Public Properties
 
         public TStream Stream { get; }
@@ -45,7 +61,7 @@ await RestartAsync()
                     .ConfigureAwait(false);
             })
             {
-                Interval = _watchdogTimerIntervalDefault
+                Interval = JsonStreamController.WatchdogTimerIntervalDefault
             };
 
             Stream.Message += (s, e) =>