main_1.rs

// Results chan, to get the final merged results to the main thread
let (results_chan, results_port) = channel();
// Gen chan, to get generated numbers from the "generator".
let (gen_chan, gen_port) = channel();
// Share the sender of the results chan to the merge component.
let merge_chan = merge(results_chan);
// Start the workers, each worker receives a clone of the "merge chan sender".
let mut square_workers: VecDeque<Sender<PipelineMsg>> = vec![square(merge_chan.clone()),
                                                             square(merge_chan.clone())]
                                                             .into_iter()
                                                             .collect();
// Start the generator, passing along the "gen chan sender"
generate(gen_chan);