Struct async_prost::AsyncProstReader [−][src]
pub struct AsyncProstReader<R, T, D> { /* fields omitted */ }
Expand description
A wrapper around an async reader that produces an asynchronous stream of prost-decoded values
Implementations
returns a reference to the internally buffered data
unwrap the AsyncProstReader
, returning the underlying reader
Trait Implementations
impl<R, T> Stream for AsyncProstReader<R, T, AsyncDestination> where
T: Message + Default,
R: AsyncRead + Unpin,
impl<R, T> Stream for AsyncProstReader<R, T, AsyncDestination> where
T: Message + Default,
R: AsyncRead + Unpin,
Attempt to pull out the next value of this stream, registering the
current task for wakeup if the value is not yet available, and returning
None
if the stream is exhausted. Read more
impl<R, T> Stream for AsyncProstReader<R, T, AsyncFrameDestination> where
R: AsyncRead + Unpin,
T: Framed + Default,
impl<R, T> Stream for AsyncProstReader<R, T, AsyncFrameDestination> where
R: AsyncRead + Unpin,
T: Framed + Default,
Attempt to pull out the next value of this stream, registering the
current task for wakeup if the value is not yet available, and returning
None
if the stream is exhausted. Read more