channelInputClosed() — netty Function Reference

Architecture documentation for the channelInputClosed() function in ReplayingDecoder.java from the netty codebase.

Function java Buffer Allocators calls 1

Entity Profile

Buffer→ Allocators→ channelInputClosed() — netty Function Reference

Dependency Diagram

graph TD
  b8aef1bf_3001_84ff_42a1_fff6ca05d0a5["channelInputClosed()"]
  acf0308a_b3b3_8956_f20c_c96385b17313["ReplayingDecoder"]
  b8aef1bf_3001_84ff_42a1_fff6ca05d0a5 -->|defined in| acf0308a_b3b3_8956_f20c_c96385b17313
  7a42f676_96b8_04a7_cf0b_eebac0c66323["callDecode()"]
  b8aef1bf_3001_84ff_42a1_fff6ca05d0a5 -->|calls| 7a42f676_96b8_04a7_cf0b_eebac0c66323
  style b8aef1bf_3001_84ff_42a1_fff6ca05d0a5 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-base/src/main/java/io/netty/handler/codec/ReplayingDecoder.java lines 324–338

    @Override
    final void channelInputClosed(ChannelHandlerContext ctx, List<Object> out) throws Exception {
        try {
            replayable.terminate();
            if (cumulation != null) {
                callDecode(ctx, internalBuffer(), out);
            } else {
                replayable.setCumulation(Unpooled.EMPTY_BUFFER);
            }
            decodeLast(ctx, replayable, out);
        } catch (Signal replay) {
            // Ignore
            replay.expect(REPLAY);
        }
    }