summaryrefslogtreecommitdiff
path: root/src/events/app.rs
diff options
context:
space:
mode:
authorOwen Jacobson <owen@grimoire.ca>2024-09-28 20:13:10 -0400
committerOwen Jacobson <owen@grimoire.ca>2024-09-28 20:13:10 -0400
commit72efedf8e96ca6e159ce6146809ee6d3a9e5a0e7 (patch)
tree78e47ae3ed1ac00cc08e95686970900acd98a69c /src/events/app.rs
parent155f6f2556b21e6b25afe096b19adcde1255c598 (diff)
Clean up use of bare tuple as a vector element for ResumePoint.
Diffstat (limited to 'src/events/app.rs')
-rw-r--r--src/events/app.rs7
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);