@@ -1395,29 +1395,34 @@ impl<T> Receiver<T> {
13951395 ///
13961396 /// # Examples
13971397 ///
1398- /// ```rust
1398+ /// ```no_run
13991399 /// use std::sync::mpsc::channel;
14001400 /// use std::thread;
14011401 /// use std::time::Duration;
14021402 ///
14031403 /// let (sender, receiver) = channel();
14041404 ///
1405- /// // Nothing is in the buffer yet
1405+ /// // nothing is in the buffer yet
14061406 /// assert!(receiver.try_iter().next().is_none());
1407- /// println!("Nothing in the buffer...");
14081407 ///
14091408 /// thread::spawn(move || {
1409+ /// thread::sleep(Duration::from_secs(1));
14101410 /// sender.send(1).unwrap();
14111411 /// sender.send(2).unwrap();
14121412 /// sender.send(3).unwrap();
14131413 /// });
14141414 ///
1415- /// println!("Going to sleep...");
1416- /// thread::sleep(Duration::from_secs(2)); // block for two seconds
1415+ /// // nothing is in the buffer yet
1416+ /// assert!(receiver.try_iter().next().is_none());
14171417 ///
1418- /// for x in receiver.try_iter() {
1419- /// println!("Got: {}", x);
1420- /// }
1418+ /// // block for two seconds
1419+ /// thread::sleep(Duration::from_secs(2));
1420+ ///
1421+ /// let mut iter = receiver.try_iter();
1422+ /// assert_eq!(iter.next(), Some(1));
1423+ /// assert_eq!(iter.next(), Some(2));
1424+ /// assert_eq!(iter.next(), Some(3));
1425+ /// assert_eq!(iter.next(), None);
14211426 /// ```
14221427 #[ stable( feature = "receiver_try_iter" , since = "1.15.0" ) ]
14231428 pub fn try_iter ( & self ) -> TryIter < T > {
0 commit comments