Struct sqlx_core::net::BufferedSocket

pub struct BufferedSocket<S> { /* private fields */ }

Implementations

impl<S: Socket> BufferedSocket<S>

pub fn new(socket: S) -> Self

where S: Sized,

pub async fn read_buffered(&mut self, len: usize) -> Result<BytesMut>

pub fn write_buffer(&self) -> &WriteBuffer

pub fn write_buffer_mut(&mut self) -> &mut WriteBuffer

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

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

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

where T: Decode<'de, C>,

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 async fn flush(&mut self) -> Result<()>

pub async fn shutdown(&mut self) -> Result<()>

pub fn shrink_buffers(&mut self)

pub fn into_inner(self) -> S

pub fn boxed(self) -> BufferedSocket<Box<dyn Socket>>