Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "async-h1"
-version = "2.3.2"
+version = "2.3.3"
 license = "MIT OR Apache-2.0"
 repository = "https://github.com/http-rs/async-h1"
 documentation = "https://docs.rs/async-h1"
@@ -21,8 +21,6 @@ edition = "2018"
 httparse = "1.3.4"
 async-std = "1.7.0"
 http-types = { version = "2.9.0", default-features = false }
-byte-pool = "0.2.2"
-lazy_static = "1.4.0"
 futures-core = "0.3.8"
 log = "0.4.11"
 pin-project = "1.0.2"

src/server/decode.rs

@@ -127,7 +127,7 @@ where
         let reader = ReadNotifier::new(reader, body_read_sender);
         let reader = BufReader::new(reader);
         req.set_body(Body::from_reader(reader, None));
-        return Ok(Some((req, BodyReader::Chunked(reader_clone))));
+        Ok(Some((req, BodyReader::Chunked(reader_clone))))
     } else if let Some(len) = content_length {
         let len = len.len();
         let reader = Arc::new(Mutex::new(reader.take(len)));

src/server/mod.rs

@@ -187,7 +187,7 @@ where
 
         if let Some(upgrade_sender) = upgrade_sender {
             upgrade_sender.send(Connection::new(self.io.clone())).await;
-            return Ok(ConnectionStatus::Close);
+            Ok(ConnectionStatus::Close)
         } else if close_connection {
             Ok(ConnectionStatus::Close)
         } else {

tests/client_decode.rs

@@ -26,7 +26,7 @@ mod client_decode {
         ])
         .await?;
 
-        assert_eq!(res.header(&headers::DATE).is_some(), true);
+        assert!(res.header(&headers::DATE).is_some());
         Ok(())
     }