udp_netmsg 0.2.0

A low cost abstraction for sending and receiving udp datagrams. Gives ability to send and receive datagrams defined by custom structs in a simple way
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

use udp_netmsg::prelude::*;
use serde::{Serialize, Deserialize};
use std::sync::Arc;

#[derive(Serialize, Deserialize)]
struct Message {
    user: String,
    message: String,
}

fn main() 
{
    let manager = Builder::init()
        .socket(String::from("0.0.0.0:40062"))
        //.use_ids(false)
        .start::<JSON>().unwrap();

    let manager = Arc::from(manager);
    let man = manager.clone();

    std::thread::spawn(move || {
        let man = man.clone();

        loop {
            match man.get::<Message>() {
                Ok((_,obj)) => println!("{} says: {}", obj.user, obj.message),
                Err(_) => {}
            }
        }
    });

    loop {
        let mut message = String::new();
        std::io::stdin().read_line(&mut message).expect("Did not enter a correct string");

        let m = Message{user: String::from("User1"), message};

        manager.send(m, String::from("127.0.0.1:40061")).unwrap();
    }
}