Struct distant_net::common::TcpTransport

pub struct TcpTransport { /* private fields */ }

Represents a Transport that leverages a TCP stream

Implementations

impl TcpTransport

pub async fn connect(addrs: impl ToSocketAddrs) -> Result<Self>

Creates a new stream by connecting to a remote machine at the specified IP address and port

pub fn ip_addr(&self) -> IpAddr

Returns the IP address that the stream is connected to

pub fn port(&self) -> u16

Returns the port that the stream is connected to

Trait Implementations

impl Debug for TcpTransport

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

Formats the value using the given formatter.

impl Reconnectable for TcpTransport

fn reconnect<'life0, 'async_trait>(
    &'life0 mut self
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
    'life0: 'async_trait,
    Self: 'async_trait,

Attempts to reconnect an already-established connection.

impl Transport for TcpTransport

fn try_read(&self, buf: &mut [u8]) -> Result<usize>

Tries to read data from the transport into the provided buffer, returning how many bytes were read.

fn try_write(&self, buf: &[u8]) -> Result<usize>

Try to write a buffer to the transport, returning how many bytes were written.

fn ready<'life0, 'async_trait>(
    &'life0 self,
    interest: Interest
) -> Pin<Box<dyn Future<Output = Result<Ready>> + Send + 'async_trait>>where
    'life0: 'async_trait,
    Self: 'async_trait,

Waits for the transport to be ready based on the given interest, returning the ready status.