encode() — netty Function Reference

Architecture documentation for the encode() function in CompatibleObjectEncoder.java from the netty codebase.

Function java Buffer Allocators

Entity Profile

Buffer→ Allocators→ encode() — netty Function Reference

Dependency Diagram

graph TD
  980441d8_26ad_cccc_ff6a_e3d158892da9["encode()"]
  0155c035_2619_c9ea_3d74_ed7c8584336c["CompatibleObjectEncoder"]
  980441d8_26ad_cccc_ff6a_e3d158892da9 -->|defined in| 0155c035_2619_c9ea_3d74_ed7c8584336c
  style 980441d8_26ad_cccc_ff6a_e3d158892da9 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-base/src/main/java/io/netty/handler/codec/serialization/CompatibleObjectEncoder.java lines 82–101

    @Override
    protected void encode(ChannelHandlerContext ctx, Serializable msg, ByteBuf out) throws Exception {
        // Suppress a warning about resource leak since oss is closed below
        ObjectOutputStream oos = newObjectOutputStream(
                new ByteBufOutputStream(out));
        try {
            if (resetInterval != 0) {
                // Resetting will prevent OOM on the receiving side.
                writtenObjects ++;
                if (writtenObjects % resetInterval == 0) {
                    oos.reset();
                }
            }

            oos.writeObject(msg);
            oos.flush();
        } finally {
            oos.close();
        }
    }