Skip to content

Commit 09aa158

Browse files
taiki-ecramertj
authored andcommitted
Fix warnings in examples
1 parent aae644a commit 09aa158

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

futures-util/src/stream/mod.rs

+1-1
Original file line numberDiff line numberDiff line change
@@ -420,7 +420,7 @@ pub trait StreamExt: Stream {
420420
/// let (tx, rx) = mpsc::unbounded();
421421
///
422422
/// thread::spawn(move || {
423-
/// for i in (1..=5) {
423+
/// for i in 1..=5 {
424424
/// tx.unbounded_send(i).unwrap();
425425
/// }
426426
/// });

futures-util/src/try_stream/mod.rs

+3-3
Original file line numberDiff line numberDiff line change
@@ -456,10 +456,10 @@ pub trait TryStreamExt: TryStream {
456456
/// use futures::stream::TryStreamExt;
457457
/// use std::thread;
458458
///
459-
/// let (mut tx, rx) = mpsc::unbounded();
459+
/// let (tx, rx) = mpsc::unbounded();
460460
///
461461
/// thread::spawn(move || {
462-
/// for i in (1..=5) {
462+
/// for i in 1..=5 {
463463
/// tx.unbounded_send(Ok(i)).unwrap();
464464
/// }
465465
/// tx.unbounded_send(Err(6)).unwrap();
@@ -614,7 +614,7 @@ pub trait TryStreamExt: TryStream {
614614
/// use futures::stream::TryStreamExt;
615615
/// use std::thread;
616616
///
617-
/// let (mut tx, rx) = mpsc::unbounded::<Result<Vec<i32>, ()>>();
617+
/// let (tx, rx) = mpsc::unbounded::<Result<Vec<i32>, ()>>();
618618
///
619619
/// thread::spawn(move || {
620620
/// for i in (0..3).rev() {

0 commit comments

Comments
 (0)