Home / Function/ testWriteListenerInvokedAfterSuccessfulChunkedInputClosed() — netty Function Reference

testWriteListenerInvokedAfterSuccessfulChunkedInputClosed() — netty Function Reference

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

Entity Profile

Dependency Diagram

graph TD
  a8ad1595_81cf_80d2_78f1_c67dc2c7981f["testWriteListenerInvokedAfterSuccessfulChunkedInputClosed()"]
  56a5cec9_e7c0_8a2d_a9b0_56df2226f2bb["ChunkedWriteHandlerTest"]
  a8ad1595_81cf_80d2_78f1_c67dc2c7981f -->|defined in| 56a5cec9_e7c0_8a2d_a9b0_56df2226f2bb
  5a87f9ac_5ede_1dc1_7d58_9144f33b262c["TestChunkedInput()"]
  a8ad1595_81cf_80d2_78f1_c67dc2c7981f -->|calls| 5a87f9ac_5ede_1dc1_7d58_9144f33b262c
  6abd9734_226e_eb7a_6ea3_c933dfb7e8bf["isClosed()"]
  a8ad1595_81cf_80d2_78f1_c67dc2c7981f -->|calls| 6abd9734_226e_eb7a_6ea3_c933dfb7e8bf
  style a8ad1595_81cf_80d2_78f1_c67dc2c7981f fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler/src/test/java/io/netty/handler/stream/ChunkedWriteHandlerTest.java lines 509–528

    @Test
    public void testWriteListenerInvokedAfterSuccessfulChunkedInputClosed() throws Exception {
        final TestChunkedInput input = new TestChunkedInput(2);
        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));
        assertTrue(writeFuture.isSuccess());
        assertTrue(inputClosedWhenListenerInvoked.get());
        assertTrue(ch.finishAndReleaseAll());
    }

Domain

Subdomains

Frequently Asked Questions

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

Analyze Your Own Codebase

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

Try Supermodel Free