connector: manager to manage thread to poll/sync from connector

3 files changed, 13 insertions, 3 deletions

diff --git a/src/client/connector/connectors.rs b/src/client/connector/connectors.rs
index 3810a4a..4c14ad9 100644
--- a/src/client/connector/connectors.rs
+++ b/src/client/connector/connectors.rs
@@ -1,4 +1,4 @@
-mod httpconnector;
+pub(crate) mod httpconnector;
 
 pub(crate) enum Connectors<'a> {
     Http(httpconnector::HTTPConnector<'a>),
diff --git a/src/client/connector/connectors/httpconnector.rs b/src/client/connector/connectors/httpconnector.rs
index 97f79dd..2bdb36a 100644
--- a/src/client/connector/connectors/httpconnector.rs
+++ b/src/client/connector/connectors/httpconnector.rs
@@ -9,7 +9,7 @@ pub(crate) struct HTTPConnector<'a> {
 }
 
 impl<'a> HTTPConnector<'a> {
-    fn new(url: &'a str) -> Result<Self, AddrParseError> {
+    pub fn new(url: &'a str) -> Result<Self, AddrParseError> {
         Ok(Self {
             prev: String::new(),
             url,
diff --git a/src/client/connector/manager.rs b/src/client/connector/manager.rs
index 9ca8a24..7227303 100644
--- a/src/client/connector/manager.rs
+++ b/src/client/connector/manager.rs
@@ -3,10 +3,20 @@ use std::thread;
 
 pub(crate) struct ConnectorManager<'a> {
     connector: connectors::Connectors<'a>,
+    thread: Option<thread::JoinHandle<!>>,
 }
 
 impl<'a> ConnectorManager<'a> {
     pub(crate) fn new(connector: connectors::Connectors<'a>) -> Self {
-        Self { connector }
+        Self {
+            connector,
+            thread: None,
+        }
+    }
+
+    pub(crate) fn start(&mut self) {
+        self.thread = Some(thread::spawn(|| loop {
+            println!("Hello, world!");
+        }))
     }
 }