Struct UdpPipeLine

pub struct UdpPipeLine { /* private fields */ }

Implementations

impl UdpPipeLine

pub async fn send_to_addr<A: Into<SocketAddr>>( &self, buf: &[u8], addr: A, ) -> Result<()>

Writing buf to the target denoted by SocketAddr via this pipeline

pub fn try_send_to_addr<A: Into<SocketAddr>>( &self, buf: &[u8], addr: A, ) -> Result<()>

Try to write buf to the target denoted by SocketAddr via this pipeline

pub async fn send_to(&self, buf: &[u8], route_key: &RouteKey) -> Result<()>

Writing buf to the target denoted by route_key via this pipeline

pub async fn send_buf_to( &self, buf: BytesMut, route_key: &RouteKey, ) -> Result<()>

pub async fn recv_from( &mut self, buf: &mut [u8], ) -> Option<Result<(usize, RouteKey)>>

Receving buf from this PipeLine usize in the Ok branch indicates how many bytes are received RouteKey in the Ok branch denotes the source where these bytes are received from

Trait Implementations

impl Drop for UdpPipeLine

fn drop(&mut self)

Executes the destructor for this type.