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

testWriteListenerInvokedAfterChannelClosedAndInputFullyConsumed() — netty Function Reference

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

Function java Buffer Search calls 3

Entity Profile

Dependency Diagram

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

Relationship Graph

Source Code

handler/src/test/java/io/netty/handler/stream/ChunkedWriteHandlerTest.java lines 551–572

    @Test
    public void testWriteListenerInvokedAfterChannelClosedAndInputFullyConsumed() throws Exception {
        // use empty input which has endOfInput = true
        final TestChunkedInput input = new TestChunkedInput(0);
        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.close(); // close channel to make handler discard the input on subsequent flush
        ch.flush();

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

Domain

Subdomains

Defined In

Calls

Source

Frequently Asked Questions

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

Analyze Your Own Codebase

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

Try Supermodel Free