Struct RUMClient 

pub struct RUMClient { /* private fields */ }

This structs encapsulates the tokio::net::TcpStream instance that will be our adapter for connecting and sending messages to a peer or server.

Implementations

impl RUMClient

pub async fn connect(ip: &str, port: u16) -> RUMResult<RUMClient>

Connect to peer and construct the client.

pub async fn accept(socket: TcpStream) -> RUMResult<RUMClient>

If a connection was already pre-established elsewhere, construct our client with the connected socket.

pub async fn send(&mut self, msg: &RUMNetMessage) -> RUMResult<()>

Send message to server.

pub async fn recv(&mut self) -> RUMResult<RUMNetMessage>

Receive message from server. This method will make calls to RUMClient::recv_some indefinitely until we have the full message or stop receiving any data.

pub async fn wait_incoming(&self) -> RUMResult<bool>

pub async fn read_ready(&self) -> bool

Check if socket is ready for reading.

pub async fn write_ready(&self) -> bool

Check if socket is ready for writing.

pub async fn get_address(&self, local: bool) -> Option<RUMString>

Returns the peer address:port as a string.

pub fn is_disconnected(&self) -> bool

pub fn disconnect(&mut self)

Trait Implementations

impl Debug for RUMClient

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

Formats the value using the given formatter.