File tree 2 files changed +4
-4
lines changed
2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -417,7 +417,7 @@ pub trait StreamExt: Stream {
417
417
/// let (tx, rx) = mpsc::unbounded();
418
418
///
419
419
/// thread::spawn(move || {
420
- /// for i in ( 1..=5) {
420
+ /// for i in 1..=5 {
421
421
/// tx.unbounded_send(i).unwrap();
422
422
/// }
423
423
/// });
Original file line number Diff line number Diff line change @@ -456,10 +456,10 @@ pub trait TryStreamExt: TryStream {
456
456
/// use futures::stream::TryStreamExt;
457
457
/// use std::thread;
458
458
///
459
- /// let (mut tx, rx) = mpsc::unbounded();
459
+ /// let (tx, rx) = mpsc::unbounded();
460
460
///
461
461
/// thread::spawn(move || {
462
- /// for i in ( 1..=5) {
462
+ /// for i in 1..=5 {
463
463
/// tx.unbounded_send(Ok(i)).unwrap();
464
464
/// }
465
465
/// tx.unbounded_send(Err(6)).unwrap();
@@ -614,7 +614,7 @@ pub trait TryStreamExt: TryStream {
614
614
/// use futures::stream::TryStreamExt;
615
615
/// use std::thread;
616
616
///
617
- /// let (mut tx, rx) = mpsc::unbounded::<Result<Vec<i32>, ()>>();
617
+ /// let (tx, rx) = mpsc::unbounded::<Result<Vec<i32>, ()>>();
618
618
///
619
619
/// thread::spawn(move || {
620
620
/// for i in (0..3).rev() {
You can’t perform that action at this time.
0 commit comments