Deque from the acceptEncodingQueue even if it's not gonna be encoded
This commit is contained in:
parent
59a1095c23
commit
fe6b71c1f0
@ -92,6 +92,11 @@ public abstract class HttpContentEncoder extends SimpleChannelHandler {
|
||||
|
||||
encoder = null;
|
||||
|
||||
String acceptEncoding = acceptEncodingQueue.poll();
|
||||
if (acceptEncoding == null) {
|
||||
throw new IllegalStateException("cannot send more responses than requests");
|
||||
}
|
||||
|
||||
String contentEncoding = m.getHeader(HttpHeaders.Names.CONTENT_ENCODING);
|
||||
if (contentEncoding != null &&
|
||||
!HttpHeaders.Values.IDENTITY.equalsIgnoreCase(contentEncoding)) {
|
||||
@ -99,11 +104,6 @@ public abstract class HttpContentEncoder extends SimpleChannelHandler {
|
||||
ctx.sendDownstream(e);
|
||||
} else {
|
||||
// Determine the content encoding.
|
||||
String acceptEncoding = acceptEncodingQueue.poll();
|
||||
if (acceptEncoding == null) {
|
||||
throw new IllegalStateException("cannot send more responses than requests");
|
||||
}
|
||||
|
||||
boolean hasContent = m.isChunked() || m.getContent().readable();
|
||||
if (hasContent && (encoder = newContentEncoder(m, acceptEncoding)) != null) {
|
||||
// Encode the content and remove or replace the existing headers
|
||||
|
Loading…
Reference in New Issue
Block a user