diff --git a/src/connection.rs b/src/connection.rs
index 83145a9..5a20abf 100644
--- a/src/connection.rs
+++ b/src/connection.rs
@@ -15,13 +15,13 @@ impl<Req: Request, Res: Response> Connection<Req, Res> {
             stream,
             address,
             token,
-            state: RequestState::Incoming(Vec::new()),
+            state: RequestState::Incoming(Req::new()),
         }
     }
 }
 
 pub enum RequestState<Req: Request, Res: Response> {
-    Incoming(Vec<u8>),
+    Incoming(Req),
     Processing(Req),
     Outgoing(Res),
 }
diff --git a/src/request_response.rs b/src/request_response.rs
index 6e4c3eb..5996604 100644
--- a/src/request_response.rs
+++ b/src/request_response.rs
@@ -1,6 +1,9 @@
 pub trait Request {
     type Response;
-    fn from_bytes(request_bytes: &[u8]) -> RequestParseResult<Self, Self::Response>
+
+    fn new() -> Self;
+    fn push_bytes(&mut self, bytes: &[u8]);
+    fn parse(&mut self) -> RequestParseResult<Self, Self::Response>
     where
         Self: Sized,
         Self::Response: Response;
diff --git a/src/tcp_server.rs b/src/tcp_server.rs
index b49f654..ec4f3bf 100644
--- a/src/tcp_server.rs
+++ b/src/tcp_server.rs
@@ -136,7 +136,7 @@ impl<
     fn process_read_event(&mut self, event: &Event) {
         let token = event.token();
         let connection = self.connections[token.0].as_mut().unwrap();
-        if let RequestState::Incoming(ref mut request_data) = connection.state {
+        if let RequestState::Incoming(ref mut req) = connection.state {
             loop {
                 let mut buffer = [0 as u8; 1024];
                 match connection.stream.read(&mut buffer) {
@@ -144,13 +144,13 @@ impl<
                         self.remove_connection(event.token()).unwrap();
                         return;
                     }
-                    Ok(len) => request_data.extend_from_slice(&buffer[..len]),
+                    Ok(len) => req.push_bytes(&buffer[..len]),
                     Err(ref e) if e.kind() == std::io::ErrorKind::WouldBlock => break,
                     Err(e) => panic!("Unexpected error: {}", e),
                 };
             }
 
-            match Req::from_bytes(&request_data) {
+            match req.parse() {
                 RequestParseResult::Complete(request) => {
                     let mut connection =
                         std::mem::replace(&mut self.connections[token.0], None).unwrap();