diff --git a/transport/src/main/java/io/netty/channel/CombinedChannelDuplexHandler.java b/transport/src/main/java/io/netty/channel/CombinedChannelDuplexHandler.java index 34dd384fa8..6304335a0f 100644 --- a/transport/src/main/java/io/netty/channel/CombinedChannelDuplexHandler.java +++ b/transport/src/main/java/io/netty/channel/CombinedChannelDuplexHandler.java @@ -187,4 +187,14 @@ public class CombinedChannelDuplexHandler msgs, ChannelPromise promise) throws Exception { outboundHandler.write(ctx, msgs, promise); } + + @Override + public void channelReadSuspended(ChannelHandlerContext ctx) throws Exception { + inboundHandler.channelReadSuspended(ctx); + } + + @Override + public void channelWritabilityChanged(ChannelHandlerContext ctx) throws Exception { + inboundHandler.channelWritabilityChanged(ctx); + } }