Code shared from the Rust Playground

playground.rs

fn main() {
    let (tx, rx): (mpsc::SyncSender<Vec<i16>>, mpsc::Receiver<Vec<i16>>) = mpsc::sync_channel(10 as usize);
    
    listen("127.0.0.1:8000",|out| {
        move |msg| {
            let d = rx.recv().expect("ERROR RECV");

            out.send("done")
        }
    }).unwrap();
}