diff options
| author | Kit La Touche <kit@transneptune.net> | 2024-09-30 21:41:36 -0400 |
|---|---|---|
| committer | Kit La Touche <kit@transneptune.net> | 2024-09-30 21:41:36 -0400 |
| commit | c0fead957c6433be1ddfbbe8a55276a4aa8fc4df (patch) | |
| tree | fb8a12519e86628349d8070a193d3ce75a82e1a8 /src/channel | |
| parent | a6a170ab5320d9ef0a2e007ac3ab75edee574fef (diff) | |
| parent | 6c054c5b8d43a818ccfa9087960dc19b286e6bb7 (diff) | |
Merge branch 'main' into feature-frontend
Diffstat (limited to 'src/channel')
| -rw-r--r-- | src/channel/app.rs | 10 |
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(()) |
