// run-pass | |
#![allow(unused_must_use)] | |
// ignore-emscripten no threads support | |
use std::thread; | |
use std::sync::mpsc::{channel, Sender}; | |
fn producer(tx: &Sender<Vec<u8>>) { | |
tx.send( | |
vec![1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, | |
13]).unwrap(); | |
} | |
pub fn main() { | |
let (tx, rx) = channel::<Vec<u8>>(); | |
let prod = thread::spawn(move|| { | |
producer(&tx) | |
}); | |
let _data: Vec<u8> = rx.recv().unwrap(); | |
prod.join(); | |
} |