diff --git a/transport/src/main/java/io/netty/channel/ChannelOutboundBuffer.java b/transport/src/main/java/io/netty/channel/ChannelOutboundBuffer.java index a52700c3d1..59bd315714 100644 --- a/transport/src/main/java/io/netty/channel/ChannelOutboundBuffer.java +++ b/transport/src/main/java/io/netty/channel/ChannelOutboundBuffer.java @@ -545,6 +545,10 @@ public final class ChannelOutboundBuffer { RECYCLER.recycle(this, handle); } + public long totalPendingWriteBytes() { + return this.totalPendingSize; + } + private static final class Entry { Object msg; ByteBuffer[] buffers;