@@ -1395,29 +1395,34 @@ impl<T> Receiver<T> {
1395
1395
///
1396
1396
/// # Examples
1397
1397
///
1398
- /// ```rust
1398
+ /// ```no_run
1399
1399
/// use std::sync::mpsc::channel;
1400
1400
/// use std::thread;
1401
1401
/// use std::time::Duration;
1402
1402
///
1403
1403
/// let (sender, receiver) = channel();
1404
1404
///
1405
- /// // Nothing is in the buffer yet
1405
+ /// // nothing is in the buffer yet
1406
1406
/// assert!(receiver.try_iter().next().is_none());
1407
- /// println!("Nothing in the buffer...");
1408
1407
///
1409
1408
/// thread::spawn(move || {
1409
+ /// thread::sleep(Duration::from_secs(1));
1410
1410
/// sender.send(1).unwrap();
1411
1411
/// sender.send(2).unwrap();
1412
1412
/// sender.send(3).unwrap();
1413
1413
/// });
1414
1414
///
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());
1417
1417
///
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);
1421
1426
/// ```
1422
1427
#[ stable( feature = "receiver_try_iter" , since = "1.15.0" ) ]
1423
1428
pub fn try_iter ( & self ) -> TryIter < T > {
0 commit comments