// Copyright 2012 The Rust Project Developers. See the COPYRIGHT // file at the top-level directory of this distribution and at // http://rust-lang.org/COPYRIGHT. // // Licensed under the Apache License, Version 2.0 or the MIT license // , at your // option. This file may not be copied, modified, or distributed // except according to those terms. #[allow(dead_assignment)]; pub fn main() { test00(); } fn test00() { let mut r: int = 0; let mut sum: int = 0; let (tx, rx) = channel(); let mut tx0 = tx.clone(); let mut tx1 = tx.clone(); let mut tx2 = tx.clone(); let mut tx3 = tx.clone(); let number_of_messages: int = 1000; let mut i: int = 0; while i < number_of_messages { tx0.send(i + 0); tx1.send(i + 0); tx2.send(i + 0); tx3.send(i + 0); i += 1; } i = 0; while i < number_of_messages { r = rx.recv(); sum += r; r = rx.recv(); sum += r; r = rx.recv(); sum += r; r = rx.recv(); sum += r; i += 1; } assert_eq!(sum, 1998000); // assert (sum == 4 * ((number_of_messages * // (number_of_messages - 1)) / 2)); }