Struct Reader 

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

Implementations

impl<S: RecvStream> Reader<S>

pub fn new(stream: S) -> Self

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

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

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)