[][src]Struct async_resol_vbus::LiveDataReader

pub struct LiveDataReader<R> where
    R: Read
{ /* fields omitted */ }

Allows reading Data variants from a Read trait object.

Examples

use resol_vbus::{FileListReader, LiveDataReader};

let files: Vec<_> = std::env::args().skip(1).collect();

let flr = FileListReader::new(files);

let mut ldr = LiveDataReader::new(0, flr);

while let Some(data) = ldr.read_data().unwrap() {
    // process the data
    println!("{}", data.id_string());
}

Methods

impl<R> LiveDataReader<R> where
    R: Read
[src]

pub fn new(channel: u8, reader: R) -> LiveDataReader<R>[src]

Constructs a LiveDataReader.

pub fn read_bytes(&mut self) -> Result<Option<&[u8]>, Error>[src]

Read from the stream until a valid blob of data is found.

pub fn read_data(&mut self) -> Result<Option<Data>, Error>[src]

Read from the stream until a valid Data variant can be decoded.

Trait Implementations

impl<R> AsMut<R> for LiveDataReader<R> where
    R: Read
[src]

impl<R> AsRef<R> for LiveDataReader<R> where
    R: Read
[src]

impl<R> Debug for LiveDataReader<R> where
    R: Read + Debug
[src]

Auto Trait Implementations

impl<R> RefUnwindSafe for LiveDataReader<R> where
    R: RefUnwindSafe

impl<R> Send for LiveDataReader<R> where
    R: Send

impl<R> Sync for LiveDataReader<R> where
    R: Sync

impl<R> Unpin for LiveDataReader<R> where
    R: Unpin

impl<R> UnwindSafe for LiveDataReader<R> where
    R: UnwindSafe

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized
[src]

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<T> From<T> for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.