Struct AsyncReadRecvStream 

pub struct AsyncReadRecvStream<R>(/* private fields */);

Implementations

impl<R> AsyncReadRecvStream<R>

pub fn new(inner: R) -> Self

Trait Implementations

impl<R: Debug> Debug for AsyncReadRecvStream<R>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<R: AsyncReadRecvStreamExtra> RecvStream for AsyncReadRecvStream<R>

async fn recv_bytes(&mut self, len: usize) -> Result<Bytes>

Receive up to len bytes from the stream, directly into a Bytes.

async fn recv_bytes_exact(&mut self, len: usize) -> Result<Bytes>

Receive exactly len bytes from the stream, directly into a Bytes.

async fn recv_exact(&mut self, buf: &mut [u8]) -> Result<()>

Receive exactly target.len() bytes from the stream.

fn stop(&mut self, code: VarInt) -> Result<()>

Stop the stream with the given error code.

fn id(&self) -> u64

Get the stream id.