mco 0.1.48

Rust Coroutine Library like go
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

#[macro_use]
extern crate mco;
extern crate native_tls;
extern crate tungstenite;

use mco::net::TcpListener;
use tungstenite::accept;

fn main() {
    let handler = co!(move || {
        let listener = TcpListener::bind(("0.0.0.0", 3000)).unwrap();
        for stream in listener.incoming() {
            co!(move || -> () {
                let mut websocket = accept(stream.unwrap()).unwrap();

                loop {
                    let msg = websocket.read_message().unwrap();

                    // Just echo back everything that the client sent to us
                    if msg.is_binary() || msg.is_text() {
                        websocket.write_message(msg).unwrap();
                    }
                }
            });
        }
    });

    println!("Websocket server running on ws://0.0.0.0:3000");
    handler.join().unwrap();
}