Struct FrameDecoder 

pub struct FrameDecoder { /* private fields */ }

Streaming frame decoder that maintains an internal buffer.

Call push_bytes with data read from the socket, then call try_decode to extract complete frames. Incomplete frames are buffered until enough data arrives.

Implementations

impl FrameDecoder

pub fn new() -> Self

Create a new frame decoder with an empty buffer.

pub fn push_bytes(&mut self, data: &[u8])

Append raw bytes received from the transport.

pub fn try_decode(&mut self) -> Result<Option<(FrameHeader, Vec<u8>)>>

Attempt to decode one complete frame from the buffer.

Returns Ok(Some((header, payload))) if a complete frame was decoded. The decoded bytes are removed from the internal buffer. Returns Ok(None) if more data is needed. Returns Err if the frame is malformed.

pub fn buffered_len(&self) -> usize

Return the number of buffered bytes waiting to be decoded.

Trait Implementations

impl Debug for FrameDecoder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for FrameDecoder

fn default() -> FrameDecoder

Returns the “default value” for a type.