summaryrefslogtreecommitdiff
path: root/src/wrappers/broadcast.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/wrappers/broadcast.rs')
-rw-r--r--src/wrappers/broadcast.rs4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/wrappers/broadcast.rs b/src/wrappers/broadcast.rs
index c8346a6..10184bf 100644
--- a/src/wrappers/broadcast.rs
+++ b/src/wrappers/broadcast.rs
@@ -14,11 +14,11 @@ use std::task::{Context, Poll};
/// [`Stream`]: trait@crate::Stream
#[cfg_attr(docsrs, doc(cfg(feature = "sync")))]
pub struct BroadcastStream<T> {
- inner: ReusableBoxFuture<(Result<T, RecvError>, Receiver<T>)>,
+ inner: ReusableBoxFuture<'static, (Result<T, RecvError>, Receiver<T>)>,
}
/// An error returned from the inner stream of a [`BroadcastStream`].
-#[derive(Debug, PartialEq)]
+#[derive(Debug, PartialEq, Clone)]
pub enum BroadcastStreamRecvError {
/// The receiver lagged too far behind. Attempting to receive again will
/// return the oldest message still retained by the channel.