diff --git a/src/concurrency/thread/crossbeam-complex.md b/src/concurrency/thread/crossbeam-complex.md index e084e148..059cf71a 100644 --- a/src/concurrency/thread/crossbeam-complex.md +++ b/src/concurrency/thread/crossbeam-complex.md @@ -53,7 +53,7 @@ fn main() { let (sendr, recvr) = (snd2.clone(), rcv1.clone()); // Spawn workers in separate threads s.spawn(move |_| { - thread::sleep(Duration::from_millis(500)); + thread::sleep(Duration::from_millis(500)); // Receive until channel closes for msg in recvr.iter() { println!("Worker {:?} received {}.",