Fix docs

Author: ohsayan

Cargo.toml

@@ -18,4 +18,4 @@ bytes = "1.0.1"
 tokio = {version = "1.5.0", features = ["net", "io-util", "io-std"]}
 
 [dev-dependencies]
-tokio = {version="1.5.0", features=["rt", "macros"]}
+tokio = {version="1.5.0", features=["rt-multi-thread", "macros"]}

src/deserializer.rs

@@ -302,7 +302,7 @@ fn read_line_and_return_next_line<'a>(pos: &mut usize, buf: &'a [u8]) -> Option<
 
 #[cfg(test)]
 #[test]
-fn test_parser() {
+fn test_deserializer_responseitem() {
     let res = "#2\n*1\n#2\n&1\n+4\nHEY!\n".as_bytes().to_owned();
     assert_eq!(
         parse(&res),
@@ -313,11 +313,17 @@ fn test_parser() {
         parse(&res),
         ClientResult::ResponseItem(DataType::RespCode(RespCode::Okay), res.len())
     );
+}
+
+#[cfg(test)]
+#[test]
+fn test_deserializer_simple_response() {
     let res = "#2\n*1\n#2\n&5\n!1\n1\n!1\n0\n+5\nsayan\n+2\nis\n+4\nbusy\n"
         .as_bytes()
         .to_owned();
+    let ret = parse(&res);
     assert_eq!(
-        parse(&res),
+        ret,
         ClientResult::SimpleResponse(
             DataGroup(vec![
                 DataType::RespCode(RespCode::NotFound),
@@ -329,4 +335,11 @@ fn test_parser() {
             res.len()
         )
     );
+    if let ClientResult::SimpleResponse(ret, _) = ret {
+        for val in ret {
+            let _ = format!("{:?}", val);
+        }
+    } else {
+        panic!("Expected a SimpleResponse with a single datagroup")
+    }
 }

src/lib.rs

@@ -41,9 +41,9 @@
 //! skytable = "0.1.0"
 //! ```
 //! Now open up your `src/main.rs` file and establish a connection to the server:
-//! ```no_run
+//! ```ignore
 //! use skytable::{Connection};
-//! async fn main() {
+//! async fn main() -> std::io::Result<()> {
 //!     let mut con = Connection::new("127.0.0.1", 2003).await.unwrap();
 //! }
 //! ```
@@ -58,7 +58,7 @@
 //! tokio = {version="1.5.0", features=["full"]}
 //! ```
 //! And your `main.rs` should now look like:
-//! ```no_run
+//! ```ignore
 //! use skytable::{Connection, Query, Response, RespCode, DataType};
 //! #[tokio::main]
 //! async fn main() -> std::io::Result<()> {
@@ -67,7 +67,7 @@
 //! ```
 //!
 //! Now let's run a [`Query`]! Add this below the previous line:
-//! ```no_run
+//! ```ignore
 //! let mut query = Query::new();
 //! query.arg("heya");
 //! let res = con.run_simple_query(query).await?;