diff options
Diffstat (limited to 'src/events/app.rs')
| -rw-r--r-- | src/events/app.rs | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/src/events/app.rs b/src/events/app.rs index 5162c67..0cdc641 100644 --- a/src/events/app.rs +++ b/src/events/app.rs @@ -112,7 +112,7 @@ impl<'a> Events<'a> { .await?; if let Some(last) = replay.last() { - resume_live_at.advance(&channel.id, last.sequence); + resume_live_at.advance(last); } replays.insert(channel.id.clone(), replay); @@ -135,10 +135,9 @@ impl<'a> Events<'a> { Ok(created_events.chain(replay).chain(live_messages).scan( resume_at, |resume_point, event| { - let channel = &event.channel_id(); match event.data { - types::ChannelEventData::Deleted(_) => resume_point.forget(channel), - _ => resume_point.advance(channel, event.sequence), + types::ChannelEventData::Deleted(_) => resume_point.forget(&event), + _ => resume_point.advance(&event), } let event = types::ResumableEvent(resume_point.clone(), event); |