encode() — netty Function Reference

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

Function java Buffer Allocators

Entity Profile

Buffer→ Allocators→ encode() — netty Function Reference

Dependency Diagram

graph TD
  e1e28d66_d746_237b_d961_ea4199245044["encode()"]
  f1589154_b31d_6110_6729_e18015dc79b2["ObjectEncoder"]
  e1e28d66_d746_237b_d961_ea4199245044 -->|defined in| f1589154_b31d_6110_6729_e18015dc79b2
  style e1e28d66_d746_237b_d961_ea4199245044 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-base/src/main/java/io/netty/handler/codec/serialization/ObjectEncoder.java lines 55–77

    @Override
    protected void encode(ChannelHandlerContext ctx, Serializable msg, ByteBuf out) throws Exception {
        int startIdx = out.writerIndex();

        ByteBufOutputStream bout = new ByteBufOutputStream(out);
        ObjectOutputStream oout = null;
        try {
            bout.write(LENGTH_PLACEHOLDER);
            oout = new CompactObjectOutputStream(bout);
            oout.writeObject(msg);
            oout.flush();
        } finally {
            if (oout != null) {
                oout.close();
            } else {
                bout.close();
            }
        }

        int endIdx = out.writerIndex();

        out.setInt(startIdx, endIdx - startIdx - 4);
    }