message-io 0.6.0

Easy asynchronous network message library
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

use super::common::{Message};

use message_io::events::{EventQueue};
use message_io::network::{Network, NetEvent, Transport};

enum Event {
    Network(NetEvent<Message>),
}

pub fn run() {
    let mut event_queue = EventQueue::new();

    let network_sender = event_queue.sender().clone();
    let mut network = Network::new(move |net_event| network_sender.send(Event::Network(net_event)));

    let listen_addr = "127.0.0.1:3000";
    match network.listen(Transport::Udp, listen_addr) {
        Ok(_) => println!("UDP Server running at {}", listen_addr),
        Err(_) => return println!("Can not listening at {}", listen_addr),
    }

    loop {
        match event_queue.receive() {
            Event::Network(net_event) => match net_event {
                NetEvent::Message(endpoint, message) => match message {
                    Message::Greetings(text) => {
                        println!("Client ({}) says: {}", endpoint.addr(), text);
                        network.send(endpoint, Message::Greetings("Hi, I hear you".into()));
                    }
                },
                NetEvent::AddedEndpoint(_) => unreachable!(), // Not be generated for UDP
                NetEvent::RemovedEndpoint(_) => unreachable!(), // Not be generated for UDP
                NetEvent::DeserializationError(_) => (),
            },
        }
    }
}