Skip to content

Commit e2ec881

Browse files
committed
Add feedback from review
1 parent a0eeac8 commit e2ec881

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

src/client.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -244,14 +244,14 @@ impl Read for Encoder {
244244
Pin::new(&mut self.request).poll_read(cx, &mut buf[bytes_read..]);
245245
let n = match inner_poll_result {
246246
Poll::Ready(Ok(n)) => n,
247+
Poll::Ready(Err(e)) => return Poll::Ready(Err(e)),
247248
Poll::Pending => {
248249
if bytes_read == 0 {
249250
return Poll::Pending;
250251
} else {
251252
return Poll::Ready(Ok(bytes_read as usize));
252253
}
253254
}
254-
e => return e,
255255
};
256256
bytes_read += n;
257257
self.body_bytes_read += n;

src/server.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -201,14 +201,14 @@ impl Read for Encoder {
201201
Pin::new(&mut self.res).poll_read(cx, &mut buf[bytes_read..upper_bound]);
202202
let new_body_bytes_read = match inner_poll_result {
203203
Poll::Ready(Ok(n)) => n,
204+
Poll::Ready(Err(e)) => return Poll::Ready(Err(e)),
204205
Poll::Pending => {
205206
if bytes_read == 0 {
206207
return Poll::Pending;
207208
} else {
208209
break;
209210
}
210211
}
211-
e => return e,
212212
};
213213
body_bytes_read += new_body_bytes_read;
214214
bytes_read += new_body_bytes_read;
@@ -254,14 +254,14 @@ impl Read for Encoder {
254254
let inner_poll_result = Pin::new(&mut self.res).poll_read(cx, &mut chunk_buf);
255255
let chunk_length = match inner_poll_result {
256256
Poll::Ready(Ok(n)) => n,
257+
Poll::Ready(Err(e)) => return Poll::Ready(Err(e)),
257258
Poll::Pending => {
258259
if bytes_read == 0 {
259260
return Poll::Pending;
260261
} else {
261262
break;
262263
}
263264
}
264-
e => return e,
265265
};
266266

267267
// serialize chunk length as hex
@@ -338,14 +338,14 @@ impl Read for Encoder {
338338
let inner_poll_result = Pin::new(chunk).poll_read(cx, &mut buf);
339339
bytes_read += match inner_poll_result {
340340
Poll::Ready(Ok(n)) => n,
341+
Poll::Ready(Err(e)) => return Poll::Ready(Err(e)),
341342
Poll::Pending => {
342343
if bytes_read == 0 {
343344
return Poll::Pending;
344345
} else {
345346
break;
346347
}
347348
}
348-
e => return e,
349349
};
350350
if bytes_read == 0 {
351351
self.state = match is_last {

0 commit comments

Comments
 (0)