actix/actix-web
1
0
Fork 0
mirror of https://github.com/fafhrd91/actix-web synced 2025-01-18 05:41:50 +01:00
Code Issues Releases Wiki Activity

do not read head payload

Browse Source
This commit is contained in:
Nikolay Kim 2018-07-06 08:11:36 +06:00
parent 2a25caf2c5
commit 9070d59ea8
2 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/client/pipeline.rs
View File

@ -17,6 +17,7 @@ use context::{ActorHttpContext, Frame};
use error::Error; use error::Error;
use error::PayloadError; use error::PayloadError;
use header::ContentEncoding; use header::ContentEncoding;
use http::Method;
use httpmessage::HttpMessage; use httpmessage::HttpMessage;
use server::input::PayloadStream; use server::input::PayloadStream;
use server::WriterState; use server::WriterState;
@ -212,6 +213,9 @@ impl Future for SendRequest {
match pl.parse() { match pl.parse() {
Ok(Async::Ready(mut resp)) => { Ok(Async::Ready(mut resp)) => {
if self.req.method() == &Method::HEAD {
pl.parser.take();
}
resp.set_pipeline(pl); resp.set_pipeline(pl);
return Ok(Async::Ready(resp)); return Ok(Async::Ready(resp));
} }

8
tests/test_server.rs
View File

@ -368,8 +368,8 @@ fn test_head_empty() {
} }
// read response // read response
// let bytes = srv.execute(response.body()).unwrap(); let bytes = srv.execute(response.body()).unwrap();
// assert!(bytes.is_empty()); assert!(bytes.is_empty());
} }
#[test] #[test]
@ -396,8 +396,8 @@ fn test_head_binary() {
} }
// read response // read response
//let bytes = srv.execute(response.body()).unwrap(); let bytes = srv.execute(response.body()).unwrap();
//assert!(bytes.is_empty()); assert!(bytes.is_empty());
} }
#[test] #[test]