diff options
Diffstat (limited to 'src/event')
| -rw-r--r-- | src/event/app.rs | 1 | ||||
| -rw-r--r-- | src/event/broadcaster.rs | 2 |
2 files changed, 2 insertions, 1 deletions
diff --git a/src/event/app.rs b/src/event/app.rs index e58bea9..32f0a97 100644 --- a/src/event/app.rs +++ b/src/event/app.rs @@ -61,6 +61,7 @@ impl<'a> Events<'a> { // Filtering on the broadcast resume point filters out messages // before resume_at, and filters out messages duplicated from // `replay_events`. + .flat_map(stream::iter) .filter(Self::resume(resume_live_at)); Ok(replay.chain(live_messages)) diff --git a/src/event/broadcaster.rs b/src/event/broadcaster.rs index de2513a..3c4efac 100644 --- a/src/event/broadcaster.rs +++ b/src/event/broadcaster.rs @@ -1,3 +1,3 @@ use crate::broadcast; -pub type Broadcaster = broadcast::Broadcaster<super::Event>; +pub type Broadcaster = broadcast::Broadcaster<Vec<super::Event>>; |