mirror of https://github.com/fafhrd91/actix-web
revert Poll match in poll_flush
This commit is contained in:
parent
7659318afe
commit
98491dd5a6
|
@ -298,16 +298,13 @@ where
|
||||||
let mut written = 0;
|
let mut written = 0;
|
||||||
while written < len {
|
while written < len {
|
||||||
match io.as_mut().poll_write(cx, &write_buf[written..]) {
|
match io.as_mut().poll_write(cx, &write_buf[written..]) {
|
||||||
Poll::Ready(Ok(n)) => {
|
Poll::Ready(Ok(0)) => {
|
||||||
if n == 0 {
|
|
||||||
return Err(DispatchError::Io(io::Error::new(
|
return Err(DispatchError::Io(io::Error::new(
|
||||||
io::ErrorKind::WriteZero,
|
io::ErrorKind::WriteZero,
|
||||||
"",
|
"",
|
||||||
)));
|
)))
|
||||||
} else {
|
|
||||||
written += n;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
Poll::Ready(Ok(n)) => written += n,
|
||||||
Poll::Pending => {
|
Poll::Pending => {
|
||||||
write_buf.advance(written);
|
write_buf.advance(written);
|
||||||
return Ok(true);
|
return Ok(true);
|
||||||
|
|
Loading…
Reference in New Issue