Function kitsune_p2p_mdns::mdns_kill_thread

source · 
pub fn mdns_kill_thread(can_run: Arc<AtomicBool>)
Expand description

Stop thread created by mdns_create_broadcast_thread()

Examples found in repository?
examples/broadcast.rs (line 19)
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

async fn main() {
    println!("Starting broadcast");
    // Create buffer
    // let buffer = [0, 1, 2];
    // let buffer: [u8; 190] = [42; 190];
    let mut buffer: Vec<u8> = Vec::new();
    for i in 0..12_u32 {
        buffer.push((i % 255) as u8);
    }
    // Launch thread
    let service_type = "bobby".to_owned();
    let service_name = (0..62).map(|_| "X").collect::<String>();
    let tx = mdns_create_broadcast_thread(service_type, service_name, &buffer);
    // Kill thread after a minute
    tokio::time::sleep(::std::time::Duration::from_secs(60)).await;
    mdns_kill_thread(tx);
}