Struct LengthDelimitedCodec 

pub struct LengthDelimitedCodec;

Length-delimited framing for stream transports (TCP).

Each message is prefixed with a 4-byte big-endian length. This codec handles framing only — it doesn’t interpret the payload.

Implementations

impl LengthDelimitedCodec

pub fn encode(payload: &[u8], buf: &mut BytesMut)

Wrap a message with a 4-byte length prefix.

pub fn decode(buf: &mut BytesMut) -> Result<Option<BytesMut>, PimError>

Try to extract a complete framed message from the buffer.

Returns:

• Ok(Some(bytes)) if a complete message was extracted
• Ok(None) if more data is needed
• Err(...) if the frame is invalid