diff options
Diffstat (limited to 'src/channel/app.rs')
| -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(()) |
