testRemoveAndFailAllReentrantFailAll() — netty Function Reference
Architecture documentation for the testRemoveAndFailAllReentrantFailAll() function in PendingWriteQueueTest.java from the netty codebase.
Entity Profile
Dependency Diagram
graph TD fe9b4976_fdd0_845c_b783_f3f9e7c11856["testRemoveAndFailAllReentrantFailAll()"] b4bff24e_be13_7693_4ece_a0ed5ee1a982["PendingWriteQueueTest"] fe9b4976_fdd0_845c_b783_f3f9e7c11856 -->|defined in| b4bff24e_be13_7693_4ece_a0ed5ee1a982 style fe9b4976_fdd0_845c_b783_f3f9e7c11856 fill:#6366f1,stroke:#818cf8,color:#fff
Relationship Graph
Source Code
transport/src/test/java/io/netty/channel/PendingWriteQueueTest.java lines 202–219
@Test
public void testRemoveAndFailAllReentrantFailAll() {
EmbeddedChannel channel = newChannel();
final PendingWriteQueue queue = new PendingWriteQueue(channel.pipeline().firstContext());
ChannelPromise promise = channel.newPromise();
promise.addListener(future -> queue.removeAndFailAll(new IllegalStateException()));
queue.add(1L, promise);
ChannelPromise promise2 = channel.newPromise();
queue.add(2L, promise2);
queue.removeAndFailAll(new Exception());
assertTrue(promise.isDone());
assertFalse(promise.isSuccess());
assertTrue(promise2.isDone());
assertFalse(promise2.isSuccess());
assertFalse(channel.finish());
}
Domain
Subdomains
Source
Frequently Asked Questions
What does testRemoveAndFailAllReentrantFailAll() do?
testRemoveAndFailAllReentrantFailAll() is a function in the netty codebase, defined in transport/src/test/java/io/netty/channel/PendingWriteQueueTest.java.
Where is testRemoveAndFailAllReentrantFailAll() defined?
testRemoveAndFailAllReentrantFailAll() is defined in transport/src/test/java/io/netty/channel/PendingWriteQueueTest.java at line 202.
Analyze Your Own Codebase
Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.
Try Supermodel Free