tokio-multicast 0.7.2

Small Tokio helpers for UDP multicast send/receive.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

use crate::{Datagram, MulticastSocket};

pub struct MulticastReceiver<'a> {
    socket: &'a MulticastSocket,
    buf_size: usize,
}

impl<'a> MulticastReceiver<'a> {
    pub fn new(socket: &'a MulticastSocket, buf_size: usize) -> Self {
        Self { socket, buf_size }
    }

    pub async fn recv(&self) -> std::io::Result<Datagram> {
        self.socket.recv_datagram(self.buf_size).await
    }
}