encode() — netty Function Reference

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

Function java Buffer Allocators

Entity Profile

Buffer→ Allocators→ encode() — netty Function Reference

Dependency Diagram

graph TD
  1e756dc0_be9b_7a92_7456_79f84a4bcbab["encode()"]
  e9d84c23_7425_9199_3e43_6da8130ce8f6["ProtobufEncoderNano"]
  1e756dc0_be9b_7a92_7456_79f84a4bcbab -->|defined in| e9d84c23_7425_9199_3e43_6da8130ce8f6
  style 1e756dc0_be9b_7a92_7456_79f84a4bcbab fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-protobuf/src/main/java/io/netty/handler/codec/protobuf/ProtobufEncoderNano.java lines 65–76

    @Override
    protected void encode(
            ChannelHandlerContext ctx, MessageNano msg, List<Object> out) throws Exception {
        final int size = msg.getSerializedSize();
        final ByteBuf buffer = ctx.alloc().heapBuffer(size, size);
        final byte[] array = buffer.array();
        CodedOutputByteBufferNano cobbn = CodedOutputByteBufferNano.newInstance(array,
                buffer.arrayOffset(), buffer.capacity());
        msg.writeTo(cobbn);
        buffer.writerIndex(size);
        out.add(buffer);
    }