1 files changed, 6 insertions, 6 deletions
diff --git a/src/events/app.rs b/src/events/app.rs
index 0cdc641..db7f430 100644
--- a/src/events/app.rs
+++ b/src/events/app.rs
@@ -24,12 +24,12 @@ use crate::{
 
 pub struct Events<'a> {
     db: &'a SqlitePool,
-    broadcaster: &'a Broadcaster,
+    events: &'a Broadcaster,
 }
 
 impl<'a> Events<'a> {
-    pub const fn new(db: &'a SqlitePool, broadcaster: &'a Broadcaster) -> Self {
-        Self { db, broadcaster }
+    pub const fn new(db: &'a SqlitePool, events: &'a Broadcaster) -> Self {
+        Self { db, events }
     }
 
     pub async fn send(
@@ -51,7 +51,7 @@ impl<'a> Events<'a> {
             .await?;
         tx.commit().await?;
 
-        self.broadcaster.broadcast(&event);
+        self.events.broadcast(&event);
         Ok(event)
     }
 
@@ -75,7 +75,7 @@ impl<'a> Events<'a> {
         tx.commit().await?;
 
         for event in events {
-            self.broadcaster.broadcast(&event);
+            self.events.broadcast(&event);
         }
 
         Ok(())
@@ -101,7 +101,7 @@ impl<'a> Events<'a> {
 
         // Subscribe before retrieving, to catch messages broadcast while we're
         // querying the DB. We'll prune out duplicates later.
-        let live_messages = self.broadcaster.subscribe();
+        let live_messages = self.events.subscribe();
 
         let mut replays = BTreeMap::new();
         let mut resume_live_at = resume_at.clone();