From 72efedf8e96ca6e159ce6146809ee6d3a9e5a0e7 Mon Sep 17 00:00:00 2001 From: Owen Jacobson Date: Sat, 28 Sep 2024 20:13:10 -0400 Subject: Clean up use of bare tuple as a vector element for ResumePoint. --- src/events/app.rs | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) (limited to 'src/events/app.rs') 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); -- cgit v1.2.3