Exposed TIMER_TICK_MILLIS to Settings

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 authors = ["Jason Housley <[email protected]>"]
-description = "Lightweight, event-driven WebSockets for Rust."
+description = "(fork) Lightweight, event-driven WebSockets for Rust."
 documentation = "https://ws-rs.org/docs"
 keywords = [
     "websocket",
@@ -10,7 +10,7 @@ keywords = [
     "web",
 ]
 license = "MIT"
-name = "ws"
+name = "qws"
 readme = "README.md"
 repository = "https://github.com/housleyjk/ws-rs"
 version = "0.7.9"

src/io.rs

@@ -31,7 +31,6 @@ type Conn<F> = Connection<<F as Factory>::Handler>;
 
 const MAX_EVENTS: usize = 1024;
 const MESSAGES_PER_TICK: usize = 256;
-const TIMER_TICK_MILLIS: u64 = 100;
 const TIMER_WHEEL_SIZE: usize = 1024;
 const TIMER_CAPACITY: usize = 65_536;
 
@@ -100,7 +99,7 @@ where
     pub fn new(factory: F, settings: Settings) -> Handler<F> {
         let (tx, rx) = mio::channel::sync_channel(settings.max_connections * settings.queue_size);
         let timer = mio_extras::timer::Builder::default()
-            .tick_duration(Duration::from_millis(TIMER_TICK_MILLIS))
+            .tick_duration(Duration::from_millis(settings.timer_tick_millis))
             .num_slots(TIMER_WHEEL_SIZE)
             .capacity(TIMER_CAPACITY)
             .build();

src/lib.rs

@@ -233,6 +233,10 @@ pub struct Settings {
     ///
     /// Default: false
     pub tcp_nodelay: bool,
+    /// Size of mio's timer each tick in milliseconds.
+    ///
+    /// Default: 100
+    pub timer_tick_millis: u64
 }
 
 impl Default for Settings {
@@ -262,6 +266,7 @@ impl Default for Settings {
             method_strict: false,
             encrypt_server: false,
             tcp_nodelay: false,
+            timer_tick_millis: 100
         }
     }
 }