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
17
18
19

use std::net::{IpAddr, Ipv4Addr, SocketAddr};

use tokio_multicast::MulticastSocket;

#[tokio::main(flavor = "current_thread")]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // Joins multiple groups and prints the tracked membership count.
    let socket = MulticastSocket::builder()
        .bind(SocketAddr::from((Ipv4Addr::UNSPECIFIED, 5000)))
        .join(IpAddr::V4(Ipv4Addr::new(239, 1, 1, 1)))
        .join(IpAddr::V4(Ipv4Addr::new(239, 1, 1, 2)))
        .build()
        .await?;

    println!("listening on {}", socket.local_addr()?);
    let groups = socket.memberships();
    println!("joined {} groups", groups.len());
    Ok(())
}