Struct Decoder 

pub struct Decoder { /* private fields */ }

Stateful streaming decoder. Feed it bytes as they arrive, call Decoder::try_next to pop off framed messages.

Implementations

impl Decoder

pub fn new(opts: DecodeOptions) -> Self

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

Append bytes to the internal buffer. The decoder does not copy again during [try_next]; ownership moves in.

pub fn try_next(&mut self) -> Result<Option<Message>, WireError>

Pop the next complete message off the buffer. Returns:

• Ok(Some(msg)) if one full frame was parsed
• Ok(None) if we need more bytes
• Err(...) on a protocol violation (malformed / bad xxh3 / …)

pub fn buffered_bytes(&self) -> usize

Number of bytes buffered but not yet parsed into a message.

Trait Implementations

impl Debug for Decoder

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

Formats the value using the given formatter.

impl Default for Decoder

fn default() -> Decoder

Returns the “default value” for a type.