Struct Decoder 

pub struct Decoder<U: UPrim> { /* private fields */ }

An incremental varint decoder for reading varints byte-by-byte from streams.

This is useful when reading from async streams where you receive one byte at a time and need to know when the varint is complete while also building up the decoded value.

Example

use commonware_codec::varint::Decoder;

let mut decoder = Decoder::<u32>::new();

// Feed bytes one at a time (e.g., from a stream)
// 300 encodes as [0xAC, 0x02]
assert_eq!(decoder.feed(0xAC).unwrap(), None); // continuation bit set, need more
assert_eq!(decoder.feed(0x02).unwrap(), Some(300)); // complete!

Implementations

impl<U: UPrim> Decoder<U>

pub fn new() -> Self

Creates a new decoder ready to receive bytes.

pub fn feed(&mut self, byte: u8) -> Result<Option<U>, Error>

Feeds a byte to the decoder.

Returns:

• Ok(Some(value)) when the varint is complete
• Ok(None) when more bytes are needed
• Err(InvalidVarint) if the varint is malformed (overflow or invalid encoding)

Trait Implementations

impl<U: Clone + UPrim> Clone for Decoder<U>

fn clone(&self) -> Decoder<U>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<U: Debug + UPrim> Debug for Decoder<U>

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

Formats the value using the given formatter.

impl<U: UPrim> Default for Decoder<U>

fn default() -> Self

Returns the “default value” for a type.