andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

[##1064] Fix problem where the LastHttpContent was changed to HttpContent and so the end was never detected

Browse Source
This commit is contained in:
Norman Maurer 2013-02-26 07:47:30 +01:00
parent 30e7ab2f7d
commit a03bd5105a
2 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
codec-http/src/main/java/io/netty/handler/codec/http/HttpContentDecoder.java
View File

@ -135,6 +135,12 @@ public abstract class HttpContentDecoder extends MessageToMessageDecoder<HttpObj
return new Object[] { header, new DefaultHttpContent(newContent), return new Object[] { header, new DefaultHttpContent(newContent),
new DefaultLastHttpContent(lastProduct)}; new DefaultLastHttpContent(lastProduct)};
} }
} else {
if (header == null) {
return new Object[] { new DefaultLastHttpContent(newContent) };
} else {
return new Object[] { header, new DefaultLastHttpContent(newContent) };
}
} }
} }
if (header == null) { if (header == null) {

6
codec-http/src/main/java/io/netty/handler/codec/http/HttpContentEncoder.java
View File

@ -187,6 +187,12 @@ public abstract class HttpContentEncoder extends MessageToMessageCodec<HttpMessa
return new Object[] { header, new DefaultHttpContent(newContent), return new Object[] { header, new DefaultHttpContent(newContent),
new DefaultLastHttpContent(lastProduct)}; new DefaultLastHttpContent(lastProduct)};
} }
} else {
if (header == null) {
return new Object[] { new DefaultLastHttpContent(newContent) };
} else {
return new Object[] { header, new DefaultLastHttpContent(newContent) };
}
} }
} }
if (header == null) { if (header == null) {