netty Architecture Docs
Home / Function/ testWriteListenerInvokedAfterFailedChunkedInputClosed() — netty Function Reference

testWriteListenerInvokedAfterFailedChunkedInputClosed() — netty Function Reference

Architecture documentation for the testWriteListenerInvokedAfterFailedChunkedInputClosed() function in ChunkedWriteHandlerTest.java from the netty codebase.

Function java Buffer Search calls 2

Entity Profile

Dependency Diagram

graph TD
  0eff8f8b_a9f6_e032_0b08_76f4cf7fed24["testWriteListenerInvokedAfterFailedChunkedInputClosed()"]
  56a5cec9_e7c0_8a2d_a9b0_56df2226f2bb["ChunkedWriteHandlerTest"]
  0eff8f8b_a9f6_e032_0b08_76f4cf7fed24 -->|defined in| 56a5cec9_e7c0_8a2d_a9b0_56df2226f2bb
  4a14cdb7_e258_429b_0e3f_db7b42d9be3e["ThrowingChunkedInput()"]
  0eff8f8b_a9f6_e032_0b08_76f4cf7fed24 -->|calls| 4a14cdb7_e258_429b_0e3f_db7b42d9be3e
  6abd9734_226e_eb7a_6ea3_c933dfb7e8bf["isClosed()"]
  0eff8f8b_a9f6_e032_0b08_76f4cf7fed24 -->|calls| 6abd9734_226e_eb7a_6ea3_c933dfb7e8bf
  style 0eff8f8b_a9f6_e032_0b08_76f4cf7fed24 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler/src/test/java/io/netty/handler/stream/ChunkedWriteHandlerTest.java lines 530–549

    @Test
    public void testWriteListenerInvokedAfterFailedChunkedInputClosed() throws Exception {
        final ThrowingChunkedInput input = new ThrowingChunkedInput(new RuntimeException());
        EmbeddedChannel ch = new EmbeddedChannel(new ChunkedWriteHandler());

        final AtomicBoolean inputClosedWhenListenerInvoked = new AtomicBoolean();
        final CountDownLatch listenerInvoked = new CountDownLatch(1);

        ChannelFuture writeFuture = ch.write(input);
        writeFuture.addListener(future -> {
            inputClosedWhenListenerInvoked.set(input.isClosed());
            listenerInvoked.countDown();
        });
        ch.flush();

        assertTrue(listenerInvoked.await(10, SECONDS));
        assertFalse(writeFuture.isSuccess());
        assertTrue(inputClosedWhenListenerInvoked.get());
        assertFalse(ch.finish());
    }

Domain

Subdomains

Defined In

Calls

Source

Frequently Asked Questions

What does testWriteListenerInvokedAfterFailedChunkedInputClosed() do?
testWriteListenerInvokedAfterFailedChunkedInputClosed() is a function in the netty codebase, defined in handler/src/test/java/io/netty/handler/stream/ChunkedWriteHandlerTest.java.
Where is testWriteListenerInvokedAfterFailedChunkedInputClosed() defined?
testWriteListenerInvokedAfterFailedChunkedInputClosed() is defined in handler/src/test/java/io/netty/handler/stream/ChunkedWriteHandlerTest.java at line 530.
What does testWriteListenerInvokedAfterFailedChunkedInputClosed() call?
testWriteListenerInvokedAfterFailedChunkedInputClosed() calls 2 function(s): ThrowingChunkedInput, isClosed.

Analyze Your Own Codebase

Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.

Try Supermodel Free