Cargo fmt

src/main.rs

@@ -1,6 +1,6 @@
 mod respparser;
-mod server;
 mod respserializer;
+mod server;
 
 fn main() {
     let port: &str = "6388";

src/respparser.rs

@@ -61,8 +61,6 @@ impl<R: BufRead> RespParser<R> {
     }
 }
 
-
-
 #[cfg(test)]
 mod resp_parser_tests {
     use super::*;
@@ -162,7 +160,7 @@ mod resp_parser_tests {
             x => panic!("Unexpected RESP type: {:?}", x),
         }
     }
-    
+
     #[test]
     fn test_parse_null() {
         let data = "*-1\r\n";

src/respserializer.rs

@@ -1,6 +1,5 @@
 use crate::respparser::RespType;
 
-
 #[derive(Debug, PartialEq)]
 pub struct RespSerializer<W: std::io::Write> {
     writer: W,
@@ -15,33 +14,32 @@ impl<W: std::io::Write> RespSerializer<W> {
         match resp {
             RespType::SimpleString(s) => {
                 writeln!(self.writer, "+{}\r", s)
-            },
+            }
             RespType::Error(s) => {
                 writeln!(self.writer, "-{}\r", s)
-            },
+            }
             RespType::Integer(i) => {
                 writeln!(self.writer, ":{}\r", i)
-            },
+            }
             RespType::BulkString(bytes) => {
                 writeln!(self.writer, "${}\r", bytes.len())?;
                 self.writer.write_all(bytes)?;
                 writeln!(self.writer, "\r")
-            },
+            }
             RespType::Array(arr) => {
                 writeln!(self.writer, "*{}\r", arr.len())?;
                 for resp in arr {
                     self.serialize(resp)?;
                 }
                 Ok(())
-            },
+            }
             RespType::Null => {
                 writeln!(self.writer, "$-1\r")
-            },
+            }
         }
     }
 }
 
-
 #[cfg(test)]
 mod resp_serializer_tests {
     use super::*;
@@ -103,4 +101,4 @@ mod resp_serializer_tests {
         serializer.serialize(&resp).unwrap();
         assert_eq!(writer, b"$-1\r\n");
     }
-}
+}

src/server.rs

@@ -14,6 +14,7 @@ fn handle_client(mut stream: TcpStream) {
     let mut serializer = RespSerializer::new(stream);
     let _ = serializer.serialize(&mock_response);
 }
+
 pub fn start_tcp_stream(port: &str) {
     let listener = TcpListener::bind(format!("127.0.0.1:{}", port)).expect("Could not bind");
     for stream in listener.incoming() {