encode() — netty Function Reference

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

Function java Buffer Allocators

Entity Profile

Buffer→ Allocators→ encode() — netty Function Reference

Dependency Diagram

graph TD
  acee52ad_6802_b5a7_8d46_6417d93bad99["encode()"]
  6ccdafb0_22c6_e381_7013_2cd0a3ddcfde["DatagramPacketEncoder"]
  acee52ad_6802_b5a7_8d46_6417d93bad99 -->|defined in| 6ccdafb0_22c6_e381_7013_2cd0a3ddcfde
  style acee52ad_6802_b5a7_8d46_6417d93bad99 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-base/src/main/java/io/netty/handler/codec/DatagramPacketEncoder.java lines 71–89

    @Override
    protected void encode(
            ChannelHandlerContext ctx, AddressedEnvelope<M, InetSocketAddress> msg, List<Object> out) throws Exception {
        assert out.isEmpty();

        encoder.encode(ctx, msg.content(), out);
        if (out.size() != 1) {
            throw new EncoderException(
                    StringUtil.simpleClassName(encoder) + " must produce only one message.");
        }
        Object content = out.get(0);
        if (content instanceof ByteBuf) {
            // Replace the ByteBuf with a DatagramPacket.
            out.set(0, new DatagramPacket((ByteBuf) content, msg.recipient(), msg.sender()));
        } else {
            throw new EncoderException(
                    StringUtil.simpleClassName(encoder) + " must produce only ByteBuf.");
        }
    }