Struct FrameBuffer 

pub struct FrameBuffer { /* private fields */ }

Streaming frame buffer: feed arbitrary byte chunks via FrameBuffer::extend and pull out complete messages via FrameBuffer::next_frame.

Implementations

impl FrameBuffer

pub fn new() -> Self

Create an empty buffer.

pub fn extend(&mut self, chunk: &[u8])

Append more bytes from the transport.

pub fn next_frame(&mut self) -> Result<Option<EventMessage>>

Try to parse the next full frame from the buffer.

Returns:

• Ok(Some(msg)) — a complete message was decoded and removed.
• Ok(None) — need more bytes.
• Err(_) — malformed frame.

Trait Implementations

impl Debug for FrameBuffer

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

Formats the value using the given formatter.

impl Default for FrameBuffer

fn default() -> FrameBuffer

Returns the “default value” for a type.