Merge branch 'main' into prop/preserve-state

1 files changed, 4 insertions, 4 deletions

diff --git a/src/broadcast.rs b/src/broadcast.rs
index bedc263..2792a18 100644
--- a/src/broadcast.rs
+++ b/src/broadcast.rs
@@ -1,8 +1,8 @@
 use std::sync::{Arc, Mutex};
 
-use futures::{future, stream::StreamExt as _, Stream};
-use tokio::sync::broadcast::{channel, Sender};
-use tokio_stream::wrappers::{errors::BroadcastStreamRecvError, BroadcastStream};
+use futures::{Stream, future, stream::StreamExt as _};
+use tokio::sync::broadcast::{Sender, channel};
+use tokio_stream::wrappers::{BroadcastStream, errors::BroadcastStreamRecvError};
 
 // Clones will share the same sender.
 #[derive(Clone)]
@@ -47,7 +47,7 @@ where
 
     // panic: if ``channel`` has not been previously registered, and was not
     // part of the initial set of channels.
-    pub fn subscribe(&self) -> impl Stream<Item = M> + std::fmt::Debug {
+    pub fn subscribe(&self) -> impl Stream<Item = M> + std::fmt::Debug + use<M> {
         let rx = self.sender().subscribe();
 
         BroadcastStream::from(rx).scan((), |(), r| {