Struct UDPMuxConn

pub struct UDPMuxConn { /* private fields */ }

A UDP mux connection.

Implementations

impl UDPMuxConn

pub fn new(params: UDPMuxConnParams) -> Self

Creates a new UDPMuxConn.

pub fn key(&self) -> &str

Returns a key identifying this connection.

pub async fn write_packet( &self, data: &[u8], addr: SocketAddr, ) -> Result<(), Error>

Writes data to the given address. Returns an error if the buffer is too short or there’s an encoding error.

pub fn is_closed(&self) -> bool

Returns true if this connection is closed.

pub fn close_rx(&self) -> Receiver<bool>

Gets a copy of the close tokio::sync::watch::Receiver that fires when this connection is closed.

pub fn close(&self)

Closes this connection.

pub fn get_addresses(&self) -> Vec<SocketAddr>

Gets the list of the addresses associated with this connection.

pub async fn add_address(&self, addr: SocketAddr)

Registers a new address for this connection.

pub fn remove_address(&self, addr: &SocketAddr)

Deregisters an address.

pub fn contains_address(&self, addr: &SocketAddr) -> bool

Returns true if the given address is associated with this connection.

Trait Implementations

impl Clone for UDPMuxConn

fn clone(&self) -> UDPMuxConn

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Conn for UDPMuxConn

fn connect<'life0, 'async_trait>( &'life0 self, _addr: SocketAddr, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn recv<'life0, 'life1, 'async_trait>( &'life0 self, _buf: &'life1 mut [u8], ) -> Pin<Box<dyn Future<Output = Result<usize, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn recv_from<'life0, 'life1, 'async_trait>( &'life0 self, buf: &'life1 mut [u8], ) -> Pin<Box<dyn Future<Output = Result<(usize, SocketAddr), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn send<'life0, 'life1, 'async_trait>( &'life0 self, _buf: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = Result<usize, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn send_to<'life0, 'life1, 'async_trait>( &'life0 self, buf: &'life1 [u8], target: SocketAddr, ) -> Pin<Box<dyn Future<Output = Result<usize, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

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

fn remote_addr(&self) -> Option<SocketAddr>

fn close<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn as_any(&self) -> &(dyn Any + Send + Sync)