Struct grin_core::ser::StreamingReader [−][src]
pub struct StreamingReader<'a> { /* fields omitted */ }
A reader that reads straight off a stream. Tracks total bytes read so we can verify we read the right number afterwards.
Implementations
impl<'a> StreamingReader<'a>
[src]
impl<'a> StreamingReader<'a>
[src]pub fn new(
stream: &'a mut dyn Read,
version: ProtocolVersion
) -> StreamingReader<'a>
[src]
pub fn new(
stream: &'a mut dyn Read,
version: ProtocolVersion
) -> StreamingReader<'a>
[src]Create a new streaming reader with the provided underlying stream. Also takes a duration to be used for each individual read_exact call.
pub fn total_bytes_read(&self) -> u64
[src]
pub fn total_bytes_read(&self) -> u64
[src]Returns the total bytes read via this streaming reader.
Trait Implementations
impl<'a> Reader for StreamingReader<'a>
[src]
impl<'a> Reader for StreamingReader<'a>
[src]Note: We use read_fixed_bytes() here to ensure our “async” I/O behaves as expected.
fn read_bytes_len_prefix(&mut self) -> Result<Vec<u8>, Error>
[src]
fn read_bytes_len_prefix(&mut self) -> Result<Vec<u8>, Error>
[src]Read a variable size vector from the underlying stream. Expects a usize
fn read_fixed_bytes(&mut self, len: usize) -> Result<Vec<u8>, Error>
[src]
fn read_fixed_bytes(&mut self, len: usize) -> Result<Vec<u8>, Error>
[src]Read a fixed number of bytes.
fn expect_u8(&mut self, val: u8) -> Result<u8, Error>
[src]
fn expect_u8(&mut self, val: u8) -> Result<u8, Error>
[src]Consumes a byte from the reader, producing an error if it doesn’t have the expected value Read more
fn protocol_version(&self) -> ProtocolVersion
[src]
fn protocol_version(&self) -> ProtocolVersion
[src]Access to underlying protocol version to support version specific deserialization logic. Read more
Auto Trait Implementations
impl<'a> !RefUnwindSafe for StreamingReader<'a>
impl<'a> !Send for StreamingReader<'a>
impl<'a> !Sync for StreamingReader<'a>
impl<'a> Unpin for StreamingReader<'a>
impl<'a> !UnwindSafe for StreamingReader<'a>
Blanket Implementations
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]pub fn borrow_mut(&mut self) -> &mut T
[src]
pub fn borrow_mut(&mut self) -> &mut T
[src]Mutably borrows from an owned value. Read more
impl<T> Same<T> for T
impl<T> Same<T> for T
type Output = T
type Output = T
Should always be Self
impl<T> UnsafeAny for T where
T: Any,
T: Any,