Struct Reader 

pub struct Reader<S: RecvStream, V> { /* private fields */ }

Implementations

impl<S: RecvStream, V> Reader<S, V>

pub fn new(stream: S, version: V) -> Self

pub async fn decode<T: Decode<V> + Debug>(&mut self) -> Result<T, Error>

where V: Clone,

pub async fn decode_maybe<T: Decode<V> + Debug>( &mut self, ) -> Result<Option<T>, Error>

where V: Clone,

pub async fn decode_peek<T: Decode<V> + Debug>(&mut self) -> Result<T, Error>

where V: Clone,

pub async fn read(&mut self, max: usize) -> Result<Option<Bytes>, Error>

pub async fn read_exact(&mut self, size: usize) -> Result<Bytes, Error>

pub async fn skip(&mut self, size: usize) -> Result<(), Error>

pub async fn closed(&mut self) -> Result<(), Error>

Wait until the stream is closed, erroring if there are any additional bytes.

pub fn abort(&mut self, err: &Error)

pub fn with_version<O>(self, version: O) -> Reader<S, O>