summaryrefslogtreecommitdiff
path: root/src/event/app.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/event/app.rs')
-rw-r--r--src/event/app.rs6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/event/app.rs b/src/event/app.rs
index 447a98f..45a9099 100644
--- a/src/event/app.rs
+++ b/src/event/app.rs
@@ -33,8 +33,8 @@ impl<'a> Events<'a> {
let mut tx = self.db.begin().await?;
- let logins = tx.users().replay(resume_at).await?;
- let login_events = logins
+ let users = tx.users().replay(resume_at).await?;
+ let user_events = users
.iter()
.map(user::History::events)
.kmerge_by(Sequence::merge)
@@ -57,7 +57,7 @@ impl<'a> Events<'a> {
.filter(Sequence::after(resume_at))
.map(Event::from);
- let replay_events = login_events
+ let replay_events = user_events
.merge_by(channel_events, Sequence::merge)
.merge_by(message_events, Sequence::merge)
.collect::<Vec<_>>();