Struct TcpChannel 

pub struct TcpChannel { /* private fields */ }

A TCP socket

Implementations

impl TcpChannel

pub fn new(runtime: Arc<dyn Runtime>, stream: Box<dyn AsyncTcpStream>) -> Self

Create a TCP socket from an existing TcpStream

pub async fn close(&mut self) -> Result<(), Error>

Close the socket

pub async fn send_to( &mut self, data: &[u8], to: SocketAddr, ) -> Result<(), Error>

Send data to the specified address

pub fn recv(&mut self) -> impl Stream<Item = (Vec<u8>, SocketAddr)> + '_

Return a stream of received data blocks

pub fn local_addr(&self) -> Result<SocketAddr, Error>

The local address of the socket

pub fn remote_addr(&self) -> Result<SocketAddr, Error>

The remoted address of the connected socket

Trait Implementations

impl Clone for TcpChannel

fn clone(&self) -> TcpChannel

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for TcpChannel

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

Formats the value using the given formatter.