diff --git a/src/client.rs b/src/client.rs
new file mode 100644
index 0000000..91f5fdb
--- /dev/null
+++ b/src/client.rs
@@ -0,0 +1,100 @@
+use std::{
+    sync::mpsc::{channel, Receiver, Sender},
+    thread::spawn,
+};
+
+pub struct Request {
+    tx: Sender<Reply>,
+}
+
+impl Request {
+    pub fn new(tx: Sender<Reply>) -> Self {
+        Self { tx: tx }
+    }
+
+    fn get_sender(&self) -> &Sender<Reply> {
+        &self.tx
+    }
+}
+
+#[cfg(test)]
+mod requests {
+    use super::*;
+    use replies::create_reply;
+
+    pub fn create_request() -> (Request, Receiver<Reply>) {
+        let (tx, rx) = channel();
+        let req = Request::new(tx);
+        (req, rx)
+    }
+
+    #[test]
+    fn new_request() {
+        let (tx, rx) = channel();
+        let req = Request::new(tx);
+        let sender = req.get_sender();
+        sender.send(create_reply()).unwrap();
+        rx.recv().unwrap();
+    }
+}
+
+pub struct Reply;
+
+impl Reply {
+    pub fn get_session(&self) -> String {
+        "id".to_string()
+    }
+
+    pub fn get_content(&self) -> String {
+        "Something goes here.".to_string()
+    }
+}
+
+#[cfg(test)]
+mod replies {
+    use super::*;
+
+    pub fn create_reply() -> Reply {
+        Reply {}
+    }
+}
+
+pub struct Client {
+    rx: Receiver<Request>,
+}
+
+impl Client {
+    fn new(rx: Receiver<Request>) -> Self {
+        Self { rx: rx }
+    }
+
+    pub fn start() -> Sender<Request> {
+        let (tx, rx) = channel();
+        spawn(move || {
+            let client = Client::new(rx);
+            client.listen();
+        });
+        tx
+    }
+
+    fn listen(&self) {
+        loop {
+            let req = self.rx.recv().unwrap();
+            req.get_sender().send(Reply {}).unwrap();
+        }
+    }
+}
+
+#[cfg(test)]
+mod clients {
+    use super::*;
+    use requests::create_request;
+
+    #[test]
+    fn start_client() {
+        let tx = Client::start();
+        let (req, rx) = create_request();
+        tx.send(req).unwrap();
+        rx.recv().unwrap();
+    }
+}
diff --git a/src/lib.rs b/src/lib.rs
index a3f9a32..4bf63a9 100644
--- a/src/lib.rs
+++ b/src/lib.rs
@@ -1,31 +1,28 @@
+mod client;
 mod field;
 
+use client::{Client, Reply, Request};
 use field::Field;
-
-pub struct Reply;
-
-impl Reply {
-    pub fn get_session(&self) -> String {
-        "id".to_string()
-    }
-
-    pub fn get_content(&self) -> String {
-        "Something goes here.".to_string()
-    }
-}
+use std::sync::mpsc::{channel, Sender};
 
 #[derive(Clone)]
-pub struct MoreThanText;
+pub struct MoreThanText {
+    tx: Sender<Request>,
+}
 
 impl MoreThanText {
     pub fn new() -> Self {
-        Self {}
+        let tx = Client::start();
+        Self { tx: tx }
     }
 
     pub fn request<F>(&self, _session: Option<F>) -> Reply
     where
         F: Into<Field>,
     {
-        Reply {}
+        let (tx, rx) = channel();
+        let req = Request::new(tx);
+        self.tx.send(req).unwrap();
+        rx.recv().unwrap()
     }
 }