Struct ConnectFrameDecoder 

pub struct ConnectFrameDecoder { /* private fields */ }

Streaming decoder for Connect frames from a byte source.

Handles split chunks, multiple frames in a single chunk, and malformed (oversized) lengths. Does NOT handle gzip decompression inline – the caller checks FLAG_GZIP and decompresses if desired.

End frames (FLAG_END set) with an empty or JSON payload are returned as ConnectFrames. The caller inspects the payload to determine whether it conveys a Connect error.

Implementations

impl ConnectFrameDecoder

pub fn new() -> Self

pub fn push( &mut self, chunk: impl AsRef<[u8]>, ) -> Result<Vec<ConnectFrame>, ConnectError>

Feed bytes into the decoder. Returns all complete frames found.

Returns an error if a frame header advertises a length that exceeds max_frame_payload (default 64 MiB).

pub fn push_with_limit( &mut self, chunk: impl AsRef<[u8]>, max_payload: usize, ) -> Result<Vec<ConnectFrame>, ConnectError>

Same as push but with an explicit max_payload limit for testing.

pub fn buffered(&self) -> usize

Return the number of buffered bytes (incomplete frame data).

Trait Implementations

impl Default for ConnectFrameDecoder

fn default() -> ConnectFrameDecoder

Returns the “default value” for a type.