Trait TryIteratorExtVarint 

pub trait TryIteratorExtVarint {
    // Required methods
    fn read_varint(self) -> Result<Option<Varint>>;
    fn read_varints(self) -> VarintIterator<Self>
       where Self: Sized + Iterator;
}

Extension trait for reading varints from byte iterators that yield Result<u8, E>.

This trait provides convenient methods to read varints directly from any iterator that yields Result<u8, E>, allowing proper error propagation. The error type E must implement Into<ProtobufError>.

Example

use ::std::io::{Cursor, Read};
use ::protobuf_core::{TryIteratorExtVarint, Varint};

let data = vec![0x96, 0x01]; // 150 in varint encoding
let mut reader = Cursor::new(data);
let iter = reader.bytes(); // Iterator<Item = Result<u8, io::Error>>
let varint = iter.read_varint().unwrap().unwrap();
assert_eq!(varint.to_uint64(), 150);

Required Methods

fn read_varint(self) -> Result<Option<Varint>>

Read a varint from this iterator.

Returns the Varint Ok(Some(varint)) if successfully read. Returns Ok(None) if no input is available (empty iterator). Returns Err(ProtobufError::VarintTooLong) if the varint exceeds MAX_VARINT_BYTES. Returns Err(ProtobufError) if an error occurs while reading bytes (the error type E is converted via Into<ProtobufError>).

fn read_varints(self) -> VarintIterator<Self>

where Self: Sized + Iterator,

Create an iterator that reads multiple varints from this iterator.

Returns an iterator that yields Result<Varint> for each varint read. The iterator stops when there are no more bytes available or an error occurs.

Example

use ::std::io::{Cursor, Read};
use ::protobuf_core::{TryIteratorExtVarint, Varint};

let data = vec![0x96, 0x01, 0x7F]; // 150 and 127 in varint encoding
let reader = Cursor::new(data);
let iter = reader.bytes();
let varints: Vec<Varint> = iter.read_varints().collect::<Result<Vec<_>, _>>().unwrap();
assert_eq!(varints.len(), 2);
assert_eq!(varints[0].to_uint64(), 150);
assert_eq!(varints[1].to_uint64(), 127);

Implementors

impl<I, E> TryIteratorExtVarint for I

where I: Iterator<Item = Result<u8, E>>, E: Into<ProtobufError>,