Struct StreamDeframer 

pub struct StreamDeframer { /* private fields */ }

An incremental deframer. Feed it arriving bytes with push; pull complete frames with drain_frames. Holds only the bytes not yet delivered (a partial frame at most), so memory stays bounded regardless of stream length.

Implementations

impl StreamDeframer

pub fn new() -> Self

pub fn push(&mut self, bytes: &[u8])

Append a newly-arrived chunk (any size, including empty).

pub fn is_empty(&self) -> bool

No un-delivered bytes remain (the stream is fully consumed up to a frame boundary).

pub fn pending(&self) -> usize

Bytes buffered but not yet delivered (a partial frame awaiting more input).

pub fn drain_frames(&mut self, f: impl FnMut(&[u8])) -> usize

Hand every COMPLETE frame currently buffered, in arrival order, to f as a borrowed body slice (zero-copy). Stops at the first incomplete frame — keeping its partial bytes for the next push — then compacts the consumed prefix so the buffer never grows unbounded. Returns how many frames were delivered.

Trait Implementations

impl Default for StreamDeframer

fn default() -> StreamDeframer

Returns the “default value” for a type.