Update mod.rs
This commit is contained in:
parent
264c9bfd3c
commit
16ad086e7f
@ -92,9 +92,7 @@ impl<T: WebApp + 'static> server::Handler<HttpStream> for PageHandler<T> {
|
|||||||
None => (None, Next::end()),
|
None => (None, Next::end()),
|
||||||
Some(f) if self.write_pos == f.content.len() => (None, Next::end()),
|
Some(f) if self.write_pos == f.content.len() => (None, Next::end()),
|
||||||
Some(f) => match encoder.write(&f.content[self.write_pos..]) {
|
Some(f) => match encoder.write(&f.content[self.write_pos..]) {
|
||||||
Ok(bytes) => {
|
Ok(bytes) => (Some(bytes), Next::write()),
|
||||||
(Some(bytes), Next::write())
|
|
||||||
},
|
|
||||||
Err(e) => match e.kind() {
|
Err(e) => match e.kind() {
|
||||||
::std::io::ErrorKind::WouldBlock => (None, Next::write()),
|
::std::io::ErrorKind::WouldBlock => (None, Next::write()),
|
||||||
_ => (None, Next::end())
|
_ => (None, Next::end())
|
||||||
|
Loading…
Reference in New Issue
Block a user