summaryrefslogtreecommitdiff
path: root/src/channel
diff options
context:
space:
mode:
authorKit La Touche <kit@transneptune.net>2024-09-30 21:41:36 -0400
committerKit La Touche <kit@transneptune.net>2024-09-30 21:41:36 -0400
commitc0fead957c6433be1ddfbbe8a55276a4aa8fc4df (patch)
treefb8a12519e86628349d8070a193d3ce75a82e1a8 /src/channel
parenta6a170ab5320d9ef0a2e007ac3ab75edee574fef (diff)
parent6c054c5b8d43a818ccfa9087960dc19b286e6bb7 (diff)
Merge branch 'main' into feature-frontend
Diffstat (limited to 'src/channel')
-rw-r--r--src/channel/app.rs10
1 files changed, 5 insertions, 5 deletions
diff --git a/src/channel/app.rs b/src/channel/app.rs
index d7312e4..70cda47 100644
--- a/src/channel/app.rs
+++ b/src/channel/app.rs
@@ -9,12 +9,12 @@ use crate::{
pub struct Channels<'a> {
db: &'a SqlitePool,
- broadcaster: &'a Broadcaster,
+ events: &'a Broadcaster,
}
impl<'a> Channels<'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 create(&self, name: &str, created_at: &DateTime) -> Result<Channel, CreateError> {
@@ -26,7 +26,7 @@ impl<'a> Channels<'a> {
.map_err(|err| CreateError::from_duplicate_name(err, name))?;
tx.commit().await?;
- self.broadcaster
+ self.events
.broadcast(&ChannelEvent::created(channel.clone()));
Ok(channel)
@@ -60,7 +60,7 @@ impl<'a> Channels<'a> {
tx.commit().await?;
for event in events {
- self.broadcaster.broadcast(&event);
+ self.events.broadcast(&event);
}
Ok(())