Threaded send/receive using channels in Rust

playground.rs

use std::thread;
use std::sync::mpsc::{ channel, Sender };

enum Wrapped {
    A(f64),
    B(f64),
}

fn produce_a(sender: Sender<Wrapped>) {
    for i in 0 .. 5 {
        sender.send( Wrapped::A(i as f64) ).unwrap();
    }
}

fn produce_b(sender: Sender<Wrapped>) {
    for i in 0 .. 8 {
        sender.send( Wrapped::B(i as f64) ).unwrap();
    }
}

fn main() {
    let (tx, rx) = channel();
    let tx2 = tx.clone();
    thread::spawn(move || produce_a(tx));
    thread::spawn(move || produce_b(tx2));
    
    let mut total_a = 0.0;
    let mut total_b = 0.0;
    loop {
        match rx.recv() {
            Ok(Wrapped::A(a)) => total_a += a,
            Ok(Wrapped::B(b)) => total_b += b,
            Err(_) => break,
        }
    }
    println!("Result - a: {}, b: {}", total_a, total_b);
}