mirror of https://github.com/http-rs/async-h1
Fix clippy warnings so that CI passes again
This commit is contained in:
parent
a1448c379b
commit
b19548e26e
|
@ -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)));
|
||||
|
|
|
@ -170,7 +170,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 {
|
||||
|
|
|
@ -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(())
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue