1 files changed, 3 insertions, 2 deletions
diff --git a/src/channel/app.rs b/src/channel/app.rs
index c0a6d60..5417a5e 100644
--- a/src/channel/app.rs
+++ b/src/channel/app.rs
@@ -4,7 +4,7 @@ use std::sync::{Arc, Mutex, MutexGuard};
 use futures::{
     future,
     stream::{self, StreamExt as _, TryStreamExt as _},
-    TryStream,
+    Stream,
 };
 use sqlx::sqlite::SqlitePool;
 use tokio::sync::broadcast::{channel, Sender};
@@ -57,7 +57,8 @@ impl<'a> Channels<'a> {
         &self,
         channel: &ChannelId,
         resume_at: Option<&DateTime>,
-    ) -> Result<impl TryStream<Ok = BroadcastMessage, Error = BoxedError>, BoxedError> {
+    ) -> Result<impl Stream<Item = Result<BroadcastMessage, BoxedError>> + 'static, BoxedError>
+    {
         fn skip_stale<E>(
             resume_at: Option<&DateTime>,
         ) -> impl for<'m> FnMut(&'m BroadcastMessage) -> future::Ready<Result<bool, E>> {