@Test public void testWithVoidPromise() { writeQueue.add(cat, voidPromise); writeQueue.add(mouse, voidPromise); assertQueueSize(8, false); assertEquals("catm", dequeue(4, newPromise())); assertQueueSize(4, false); assertEquals("ouse", dequeue(4, newPromise())); assertQueueSize(0, true); assertEquals(0, cat.refCnt()); assertEquals(0, mouse.refCnt()); }
public void add(ByteBuf buf) { add(buf, (ChannelFutureListener) null); }
CoalescingBufferQueue { public void add(ByteBuf buf) { add(buf, (ChannelFutureListener) null); } }
CoalescingBufferQueue { public void add(ByteBuf buf) { add(buf, (ChannelFutureListener) null); } CoalescingBufferQueue(Channel channel);  CoalescingBufferQueue(Channel channel, int initSize); }
CoalescingBufferQueue { public void add(ByteBuf buf) { add(buf, (ChannelFutureListener) null); } CoalescingBufferQueue(Channel channel);  CoalescingBufferQueue(Channel channel, int initSize); void add(ByteBuf buf); void add(ByteBuf buf, ChannelPromise promise); void add(ByteBuf buf, ChannelFutureListener listener); ByteBuf remove(int bytes, ChannelPromise aggregatePromise); int readableBytes(); boolean isEmpty(); void releaseAndFailAll(Throwable cause); void copyTo(CoalescingBufferQueue dest); }
CoalescingBufferQueue { public void add(ByteBuf buf) { add(buf, (ChannelFutureListener) null); } CoalescingBufferQueue(Channel channel);  CoalescingBufferQueue(Channel channel, int initSize); void add(ByteBuf buf); void add(ByteBuf buf, ChannelPromise promise); void add(ByteBuf buf, ChannelFutureListener listener); ByteBuf remove(int bytes, ChannelPromise aggregatePromise); int readableBytes(); boolean isEmpty(); void releaseAndFailAll(Throwable cause); void copyTo(CoalescingBufferQueue dest);  }