testAllNotIdle() — netty Function Reference

Architecture documentation for the testAllNotIdle() function in IdleStateHandlerTest.java from the netty codebase.

Function java Buffer Allocators calls 1

Entity Profile

Buffer→ Allocators→ testAllNotIdle() — netty Function Reference

Dependency Diagram

graph TD
  aeca092e_f735_2f22_7a48_f255e8d4cdbc["testAllNotIdle()"]
  f1a156c3_6366_afc7_6b64_9543e5f91ba9["IdleStateHandlerTest"]
  aeca092e_f735_2f22_7a48_f255e8d4cdbc -->|defined in| f1a156c3_6366_afc7_6b64_9543e5f91ba9
  1cc6fb30_92ac_540a_93b5_d0513d5059f6["anyNotIdle()"]
  aeca092e_f735_2f22_7a48_f255e8d4cdbc -->|calls| 1cc6fb30_92ac_540a_93b5_d0513d5059f6
  style aeca092e_f735_2f22_7a48_f255e8d4cdbc fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler/src/test/java/io/netty/handler/timeout/IdleStateHandlerTest.java lines 161–188

    @Test
    public void testAllNotIdle() throws Exception {
        // Reader...
        IdleStateHandler idleStateHandler = new IdleStateHandler(
                false, 0L, 0L, 1L, TimeUnit.SECONDS);

        Action reader = new Action() {
            @Override
            public void run(EmbeddedChannel channel) throws Exception {
                channel.writeInbound("Hello, World!");
            }
        };

        anyNotIdle(idleStateHandler, reader, IdleStateEvent.FIRST_ALL_IDLE_STATE_EVENT);

        // Writer...
        idleStateHandler = new IdleStateHandler(
                false, 0L, 0L, 1L, TimeUnit.SECONDS);

        Action writer = new Action() {
            @Override
            public void run(EmbeddedChannel channel) throws Exception {
                channel.writeAndFlush("Hello, World!");
            }
        };

        anyNotIdle(idleStateHandler, writer, IdleStateEvent.FIRST_ALL_IDLE_STATE_EVENT);
    }