simple_receiver/
simple_receiver.rs

1use std::net::{IpAddr, Ipv4Addr, SocketAddr};
2
3use tokio_multicast::MulticastSocket;
4
5#[tokio::main(flavor = "current_thread")]
6async fn main() -> Result<(), Box<dyn std::error::Error>> {
7    // Listens on a multicast group until interrupted.
8    let socket = MulticastSocket::builder()
9        .bind(SocketAddr::from((Ipv4Addr::UNSPECIFIED, 46053)))
10        .join(IpAddr::V4(Ipv4Addr::new(239, 1, 1, 10)))
11        .build()
12        .await?;
13
14    let mut buf = [0_u8; 2048];
15    loop {
16        let (n, from) = socket.recv_from(&mut buf).await?;
17        println!("received {n} bytes from {from}");
18    }
19}

simple_receiver/simple_receiver.rs

simple_receiver/
simple_receiver.rs