1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use futures_util::{self, pin_mut, stream::StreamExt};
use kitsune_p2p_mdns::*;

#[tokio::main]
async fn main() {
    println!("Starting discovery");
    let service_name = "bobby".to_owned();
    // Start Stream
    let stream = mdns_listen(service_name);
    pin_mut!(stream);
    while let Some(maybe_response) = stream.next().await {
        match maybe_response {
            Ok(response) => {
                println!("Discovered: {:?}", response);
            }
            Err(e) => {
                println!("!!! Discovery Error: {:?}", e);
            }
        }
    }
}