testCancelWrite() — netty Function Reference

Architecture documentation for the testCancelWrite() function in DefaultChannelPipelineTest.java from the netty codebase.

Function java Buffer Telemetry calls 1

Entity Profile

Buffer→ Telemetry→ testCancelWrite() — netty Function Reference

Dependency Diagram

graph TD
  61a24c53_e6f1_6745_3614_87272434c1b2["testCancelWrite()"]
  666d912b_4166_a807_ed10_ba12f328a7b2["DefaultChannelPipelineTest"]
  61a24c53_e6f1_6745_3614_87272434c1b2 -->|defined in| 666d912b_4166_a807_ed10_ba12f328a7b2
  1bb1c1cc_77dd_d360_5aff_fec13914d331["write()"]
  61a24c53_e6f1_6745_3614_87272434c1b2 -->|calls| 1bb1c1cc_77dd_d360_5aff_fec13914d331
  style 61a24c53_e6f1_6745_3614_87272434c1b2 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/DefaultChannelPipelineTest.java lines 1086–1098

    @Test
    public void testCancelWrite() {
        ChannelPipeline pipeline = new LocalChannel().pipeline();
        group.register(pipeline.channel());

        ChannelPromise promise = pipeline.channel().newPromise();
        assertTrue(promise.cancel(false));
        ByteBuf buffer = Unpooled.buffer();
        assertEquals(1, buffer.refCnt());
        ChannelFuture future = pipeline.write(buffer, promise);
        assertTrue(future.isCancelled());
        assertEquals(0, buffer.refCnt());
    }