EmbeddedChannel() — netty Function Reference

Architecture documentation for the EmbeddedChannel() function in FlushConsolidationHandlerTest.java from the netty codebase.

Function java Buffer Allocators

Entity Profile

Buffer→ Allocators→ EmbeddedChannel() — netty Function Reference

Dependency Diagram

graph TD
  62fc1ef5_5ea5_e8d0_1179_f609de9d9d52["EmbeddedChannel()"]
  4ef52a0d_d145_a738_5ebe_4e1ee02cb2ca["FlushConsolidationHandlerTest"]
  62fc1ef5_5ea5_e8d0_1179_f609de9d9d52 -->|defined in| 4ef52a0d_d145_a738_5ebe_4e1ee02cb2ca
  style 62fc1ef5_5ea5_e8d0_1179_f609de9d9d52 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler/src/test/java/io/netty/handler/flush/FlushConsolidationHandlerTest.java lines 181–197

    private static EmbeddedChannel newChannel(final AtomicInteger flushCount, boolean consolidateWhenNoReadInProgress) {
        return new EmbeddedChannel(
                new ChannelOutboundHandlerAdapter() {
                    @Override
                    public void flush(ChannelHandlerContext ctx) throws Exception {
                        flushCount.incrementAndGet();
                        ctx.flush();
                    }
                },
                new FlushConsolidationHandler(EXPLICIT_FLUSH_AFTER_FLUSHES, consolidateWhenNoReadInProgress),
                new ChannelInboundHandlerAdapter() {
                    @Override
                    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
                        ctx.writeAndFlush(msg);
                    }
                });
    }