Struct TcpClient

pub struct TcpClient<T> { /* private fields */ }

Implementations

impl TcpClient<TcpStream>

pub async fn connect<T: ToSocketAddrs, F: Future<Output = Result<bool>> + Send + 'static, A: Send + 'static>( addr: T, input: impl FnOnce(A, Arc<Actor<TcpClient<TcpStream>>>, ReadHalf<TcpStream>) -> F + Send + 'static, token: A, ) -> Result<Arc<Actor<TcpClient<TcpStream>>>>

impl<T> TcpClient<T>

where T: AsyncRead + AsyncWrite + Send + 'static,

pub async fn connect_stream_type<H: ToSocketAddrs, F: Future<Output = Result<bool>> + Send + 'static, S: Future<Output = Result<T>> + Send + 'static, A: Send + 'static>( addr: H, stream_init: impl FnOnce(TcpStream) -> S + Send + 'static, input: impl FnOnce(A, Arc<Actor<TcpClient<T>>>, ReadHalf<T>) -> F + Send + 'static, token: A, ) -> Result<Arc<Actor<TcpClient<T>>>>

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

pub async fn send(&mut self, buff: &[u8]) -> Result<usize>

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