fix bounded sender len and is_empty examples

tokio-rs · Jan 15, 2025 · 1689ba1 · 1689ba1
1 parent 79ab386
commit 1689ba1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/tokio/src/sync/mpsc/bounded.rs b/tokio/src/sync/mpsc/bounded.rs
@@ -1069,7 +1069,7 @@ impl<T> Sender<T> {
     ///
     /// #[tokio::main]
     /// async fn main() {
-    ///     let (tx, rx) = mpsc::unbounded_channel();
+    ///     let (tx, rx) = mpsc::channel(10);
     ///     assert!(rx.is_empty());
     ///
     ///     tx.send(0).await.unwrap();
@@ -1088,7 +1088,7 @@ impl<T> Sender<T> {
     ///
     /// #[tokio::main]
     /// async fn main() {
-    ///     let (tx, rx) = mpsc::unbounded_channel();
+    ///     let (tx, rx) = mpsc::channel(10);
     ///     assert_eq!(0, rx.len());
     ///
     ///     tx.send(0).await.unwrap();