Struct SharedMulticastUdpSocket

pub struct SharedMulticastUdpSocket { /* private fields */ }

A multicast socket with shared .recv_from(). It’ll call all subscribed handlers. You MUST spawn task_listen_forever().

Implementations

impl SharedMulticastUdpSocket

pub fn new(sock: MulticastUdpSocket) -> Result<Arc<Self>>

pub fn add_handler( self: &Arc<Self>, handler: Box<dyn Fn(&[u8], SocketAddr) + Send + Sync + 'static>, )

pub async fn send_to(&self, buf: &[u8], addr: SocketAddr) -> Result<usize>

pub async fn task_listen_forever(self: Arc<Self>) -> Result<()>

pub async fn try_send_mcast_everywhere( &self, get_payload: &impl Fn(&MulticastOpts) -> Option<String>, )