Struct BufStream 

pub struct BufStream<S>
where
    S: AsyncRead + AsyncWrite + Unpin,
{
    pub stream: S,
    pub wbuf: Vec<u8>,
    pub rbuf: BytesMut,
}

Fields

stream: S

wbuf: Vec<u8>

rbuf: BytesMut

Implementations

impl<S> BufStream<S>

where S: AsyncRead + AsyncWrite + Unpin,

pub fn new(stream: S) -> Self

pub fn write<'en, T>(&mut self, value: T)

where T: Encode<'en, ()>,

pub fn write_with<'en, T, C>(&mut self, value: T, context: C)

where T: Encode<'en, C>,

pub fn flush(&mut self) -> WriteAndFlush<'_, S>

pub async fn read<'de, T>(&mut self, cnt: usize) -> Result<T, Error>

where T: Decode<'de, ()>,

pub async fn read_with<'de, T, C>( &mut self, cnt: usize, context: C, ) -> Result<T, Error>

where T: Decode<'de, C>,

pub async fn read_raw(&mut self, cnt: usize) -> Result<BytesMut, Error>

pub async fn read_raw_into( &mut self, buf: &mut BytesMut, cnt: usize, ) -> Result<(), Error>

Trait Implementations

impl<S> Deref for BufStream<S>

where S: AsyncRead + AsyncWrite + Unpin,

type Target = S

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<S> DerefMut for BufStream<S>

where S: AsyncRead + AsyncWrite + Unpin,

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.