mirrors/actix-web
1
0
Fork 0
mirror of https://github.com/actix/actix-web.git synced 2024-11-03 15:39:50 +00:00
Code Issues Projects Releases Wiki Activity

Add some comments to clarify logic.

Browse source
This commit is contained in:
Robert G. Jakabosky 2018-09-01 02:15:36 +08:00
parent 2341656173
commit a42a8a2321
1 changed files with 4 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/client/parser.rs
View file

@ -39,6 +39,7 @@ impl HttpResponseParser {
T: IoStream,
{
loop {
// Read some more data into the buffer for the parser.
match io.read_available(buf) {
Ok(Async::Ready((false, true))) => {
return Err(HttpResponseParserError::Disconnect)
@ -49,6 +50,8 @@ impl HttpResponseParser {
return Err(HttpResponseParserError::Error(err.into()))
}
}
// Call HTTP response parser.
match HttpResponseParser::parse_message(buf)
.map_err(HttpResponseParserError::Error)?
{
@ -60,6 +63,7 @@ impl HttpResponseParser {
if buf.capacity() >= MAX_BUFFER_SIZE {
return Err(HttpResponseParserError::Error(ParseError::TooLarge));
}
// Parser needs more data. Loop and read more data.
}
}
}