diff --git a/CHANGES.md b/CHANGES.md index 13d31397a..674a99548 100644 --- a/CHANGES.md +++ b/CHANGES.md @@ -1,5 +1,8 @@ # Changes +* Drop connection if request's payload is not fulle consumed #236 + + ## 0.6.8 (2018-05-20) * Fix scope resource path extractor #234 diff --git a/src/server/h1.rs b/src/server/h1.rs index 491c667c3..d7edd2dcf 100644 --- a/src/server/h1.rs +++ b/src/server/h1.rs @@ -270,7 +270,12 @@ where debug!("Error sending data: {}", err); return Err(()); } - _ => (), + Ok(Async::Ready(_)) => { + // non consumed payload in that case close connection + if self.payload.is_some() && self.tasks.is_empty() { + return Ok(Async::Ready(false)) + } + } } }