Struct StatefulTcpReader

pub struct StatefulTcpReader {
    buf: [u8; 5192],
    buf_len: usize,
    used_len: usize,
}

Fields

buf: [u8; 5192]

buf_len: usize

used_len: usize

Implementations

impl StatefulTcpReader

pub fn new() -> Self

pub fn clear(&mut self)

pub async fn try_read_socket<'a, T: DeserializeOwned>( &'a mut self, socket: &mut (impl Read + ReadReady), ) -> Result<TcpMessage<'a, T>, TcpError>

pub async fn read_socket<'a, T: DeserializeOwned>( &'a mut self, socket: &mut impl Read, ) -> Result<TcpMessage<'a, T>, TcpError>

pub fn read_u8_ref<'a, T: DeserializeOwned>( &'a mut self, buf: &mut &[u8], ) -> Result<TcpMessage<'a, T>, TcpError>

fn clear_used(&mut self)

fn has_message(&mut self) -> bool

fn fetch_message<T: DeserializeOwned>( &mut self, ) -> Result<Option<TcpMessage<'_, T>>, TcpError>

Trait Implementations

impl Default for StatefulTcpReader

fn default() -> Self

Returns the “default value” for a type.