1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20

pub mod spsc;

#[cfg(test)]
mod tests {
  use super::*;

  #[test]
  fn with_spawn() {
    use std::thread;
    let (mut tx, mut rx) = spsc::channel(2, 0 as i32);
    let t = thread::spawn(move|| {
      for i in 1..4 {
        tx.put(|v| *v = i);
      }
    });
    t.join().unwrap();
    let sum = rx.iter().fold(0, |acc, num| acc + num);
    assert_eq!(sum, 5);
  }
}