diff --git a/tokio/src/sync/broadcast.rs b/tokio/src/sync/broadcast.rs index 33a15805ad6..c796d129920 100644 --- a/tokio/src/sync/broadcast.rs +++ b/tokio/src/sync/broadcast.rs @@ -901,7 +901,8 @@ impl Receiver { /// let mut rx2 = rx.resubscribe(); /// tx.send(2).unwrap(); /// - /// assert_eq!(rx.recv().await.unwrap(), rx2.recv().await.unwrap()); // 1 != 2 + /// assert_eq!(rx2.recv().await.unwrap(), 2); + /// assert_eq!(rx.recv().await.unwrap(), 1); /// } /// ``` pub fn resubscribe(&self) -> Self {