diff --git a/transport/src/main/java/io/netty/channel/ChannelInboundByteHandlerAdapter.java b/transport/src/main/java/io/netty/channel/ChannelInboundByteHandlerAdapter.java index 89f6d6a625..85aaafbe10 100644 --- a/transport/src/main/java/io/netty/channel/ChannelInboundByteHandlerAdapter.java +++ b/transport/src/main/java/io/netty/channel/ChannelInboundByteHandlerAdapter.java @@ -34,7 +34,7 @@ public abstract class ChannelInboundByteHandlerAdapter inboundBufferUpdated(ctx, in); } finally { if (!in.readable()) { - in.discardReadBytes(); + in.unsafe().discardSomeReadBytes(); } } }