Skip to content

Commit 7161991

Browse files
jbryoshuawuyts
andauthored
Apply suggestions from code review
Co-authored-by: Yoshua Wuyts <[email protected]>
1 parent e8f4609 commit 7161991

File tree

2 files changed

+7
-13
lines changed

2 files changed

+7
-13
lines changed

src/read_notifier.rs

Lines changed: 5 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,9 @@
1-
use std::{
2-
fmt, io,
3-
pin::Pin,
4-
task::{Context, Poll},
5-
};
1+
use std::fmt;
2+
use std::pin::Pin;
3+
use std::task::{Context, Poll};
64

7-
use async_std::{
8-
io::{BufRead, Read},
9-
sync::Sender,
10-
};
5+
use async_std::io::{self, BufRead, Read};
6+
use async_std::sync::Sender;
117

128
pin_project_lite::pin_project! {
139
pub(crate) struct ReadNotifier<B>{

src/server/decode.rs

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -102,10 +102,8 @@ where
102102
if let Some(encoding) = transfer_encoding {
103103
if encoding.last().as_str() == "chunked" {
104104
let trailer_sender = req.send_trailers();
105-
let reader = ReadNotifier::new(
106-
BufReader::new(ChunkedDecoder::new(reader, trailer_sender)),
107-
sender,
108-
);
105+
let reader = BufReader::new(ChunkedDecoder::new(reader, trailer_sender));
106+
let reader = ReadNotifier::new(reader, sender);
109107
req.set_body(Body::from_reader(reader, None));
110108
return Ok(Some(req));
111109
}

0 commit comments

Comments
 (0)