chan.rs

// The standard library imports.
use std::sync::mpsc::channel;
use std::thread::spawn;
use std::sync::Mutex;

use rouille;

fn main() {
    println!("Hello, world!");
    
    // Create a channel pair. They are distinct types unlike in Go.
    let (tx, rx) = channel();
    let mtx = Mutex::new(tx);
    
    // spawn(move || {
    // });
    spawn(move || {
        rouille::start_server("localhost:9090", move |request| {
            rouille::router!(request,
                (GET) (/status) => {
                    rouille::Response::text("ok")
                },
                (GET) (/shutdown) => {
                    mtx.lock().unwrap().send(1).unwrap();
                    rouille::Response::text("quitting")
                },
                _ => {
                    rouille::Response::empty_404()
                }
            )
        });
    });
    
    // Receive the value and ignore the error by calling `unwrap`.
    println!("received value {:?}", rx.recv().unwrap());
    
}