testCloseChannelOnCreation() — netty Function Reference

Architecture documentation for the testCloseChannelOnCreation() function in PendingWriteQueueTest.java from the netty codebase.

Function java Buffer Telemetry

Entity Profile

Buffer→ Telemetry→ testCloseChannelOnCreation() — netty Function Reference

Dependency Diagram

graph TD
  7e51edc5_f039_b4bc_b9a0_3e7f994f21e0["testCloseChannelOnCreation()"]
  b4bff24e_be13_7693_4ece_a0ed5ee1a982["PendingWriteQueueTest"]
  7e51edc5_f039_b4bc_b9a0_3e7f994f21e0 -->|defined in| b4bff24e_be13_7693_4ece_a0ed5ee1a982
  style 7e51edc5_f039_b4bc_b9a0_3e7f994f21e0 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/test/java/io/netty/channel/PendingWriteQueueTest.java lines 332–345

    @Test
    public void testCloseChannelOnCreation() {
        EmbeddedChannel channel = newChannel();
        ChannelHandlerContext context = channel.pipeline().firstContext();
        channel.close().syncUninterruptibly();

        final PendingWriteQueue queue = new PendingWriteQueue(context);

        IllegalStateException ex = new IllegalStateException();
        ChannelPromise promise = channel.newPromise();
        queue.add(1L, promise);
        queue.removeAndFailAll(ex);
        assertSame(ex, promise.cause());
    }