Fix warnings in examples

rust-lang · Jun 26, 2019 · 8e4e225 · 8e4e225
1 parent c9772a6
commit 8e4e225
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/futures-util/src/stream/mod.rs b/futures-util/src/stream/mod.rs
@@ -417,7 +417,7 @@ pub trait StreamExt: Stream {
     /// let (tx, rx) = mpsc::unbounded();
     ///
     /// thread::spawn(move || {
-    ///     for i in (1..=5) {
+    ///     for i in 1..=5 {
     ///         tx.unbounded_send(i).unwrap();
     ///     }
     /// });

diff --git a/futures-util/src/try_stream/mod.rs b/futures-util/src/try_stream/mod.rs
@@ -456,10 +456,10 @@ pub trait TryStreamExt: TryStream {
     /// use futures::stream::TryStreamExt;
     /// use std::thread;
     ///
-    /// let (mut tx, rx) = mpsc::unbounded();
+    /// let (tx, rx) = mpsc::unbounded();
     ///
     /// thread::spawn(move || {
-    ///     for i in (1..=5) {
+    ///     for i in 1..=5 {
     ///         tx.unbounded_send(Ok(i)).unwrap();
     ///     }
     ///     tx.unbounded_send(Err(6)).unwrap();
@@ -614,7 +614,7 @@ pub trait TryStreamExt: TryStream {
     /// use futures::stream::TryStreamExt;
     /// use std::thread;
     ///
-    /// let (mut tx, rx) = mpsc::unbounded::<Result<Vec<i32>, ()>>();
+    /// let (tx, rx) = mpsc::unbounded::<Result<Vec<i32>, ()>>();
     ///
     /// thread::spawn(move || {
     ///     for i in (0..3).rev() {