@Test public void testReleaseAndFailAll() { writeQueue.add(cat, catPromise); writeQueue.add(mouse, mouseListener); RuntimeException cause = new RuntimeException("ooops"); writeQueue.releaseAndFailAll(cause); ChannelPromise aggregatePromise = newPromise(); assertQueueSize(0, true); assertEquals(0, cat.refCnt()); assertEquals(0, mouse.refCnt()); assertSame(cause, catPromise.cause()); assertEquals("", dequeue(Integer.MAX_VALUE, aggregatePromise)); assertQueueSize(0, true); }
public void releaseAndFailAll(Throwable cause) { releaseAndFailAll(channel, cause); }
CoalescingBufferQueue extends AbstractCoalescingBufferQueue { public void releaseAndFailAll(Throwable cause) { releaseAndFailAll(channel, cause); } }
CoalescingBufferQueue extends AbstractCoalescingBufferQueue { public void releaseAndFailAll(Throwable cause) { releaseAndFailAll(channel, cause); } CoalescingBufferQueue(Channel channel);  CoalescingBufferQueue(Channel channel, int initSize);  CoalescingBufferQueue(Channel channel, int initSize, boolean updateWritability); }
CoalescingBufferQueue extends AbstractCoalescingBufferQueue { public void releaseAndFailAll(Throwable cause) { releaseAndFailAll(channel, cause); } CoalescingBufferQueue(Channel channel);  CoalescingBufferQueue(Channel channel, int initSize);  CoalescingBufferQueue(Channel channel, int initSize, boolean updateWritability); ByteBuf remove(int bytes, ChannelPromise aggregatePromise); void releaseAndFailAll(Throwable cause); }
CoalescingBufferQueue extends AbstractCoalescingBufferQueue { public void releaseAndFailAll(Throwable cause) { releaseAndFailAll(channel, cause); } CoalescingBufferQueue(Channel channel);  CoalescingBufferQueue(Channel channel, int initSize);  CoalescingBufferQueue(Channel channel, int initSize, boolean updateWritability); ByteBuf remove(int bytes, ChannelPromise aggregatePromise); void releaseAndFailAll(Throwable cause);  }