rust channel

use std::sync::mpsc;
use std::thread;
use std::time::Duration;

pub fn f_channel() {
    let (tx, rx) = mpsc::channel();
    let tx1 = tx.clone();
    thread::spawn(move || {
        let vec = vec![
            "hi",
            "tom",
            "aaa",
        ];
        for v in vec{
            tx1.send(v).unwrap();
            thread::sleep(Duration::from_secs(1));
        }
    });

    thread::spawn(move || {
        let vec = vec![
            "hi",
            "tom",
            "aaa",
        ];
        for v in vec{
            tx.send(v).unwrap();
            thread::sleep(Duration::from_secs(1));
        }
    });


    for received in rx {
        println!("Got: {}", received);
    }
    //let received = rx.recv().unwrap();

}

mod tests {
    use crate::channel::f_channel;

    #[test]
    fn test_channel() {
        f_channel();
    }
}

Got: hi
Got: hi
Got: tom
Got: tom
Got: aaa
Got: aaa