diff --git a/codec/src/main/java/io/netty/handler/codec/embedder/EmbeddedChannel.java b/codec/src/main/java/io/netty/handler/codec/embedder/EmbeddedChannel.java index 5e1420c415..019f17f234 100644 --- a/codec/src/main/java/io/netty/handler/codec/embedder/EmbeddedChannel.java +++ b/codec/src/main/java/io/netty/handler/codec/embedder/EmbeddedChannel.java @@ -109,13 +109,11 @@ class EmbeddedChannel extends AbstractChannel { int byteBufLen = byteBuf.readableBytes(); if (byteBufLen > 0) { productQueue.add(byteBuf.readBytes(byteBufLen)); - writeCounter += byteBufLen; byteBuf.clear(); } Queue msgBuf = buf.messageBuffer(); if (!msgBuf.isEmpty()) { productQueue.addAll(msgBuf); - writeCounter += msgBuf.size(); msgBuf.clear(); } }