diff options
Diffstat (limited to 'src/message_subscriptions.rs')
| -rw-r--r-- | src/message_subscriptions.rs | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/message_subscriptions.rs b/src/message_subscriptions.rs index 5b1d276..17d924f 100644 --- a/src/message_subscriptions.rs +++ b/src/message_subscriptions.rs @@ -4,11 +4,11 @@ use jid::BareJID; use tokio::sync::mpsc::{self, Receiver}; use uuid::Uuid; -use crate::message::MacawMessage; +use crate::message::{ArcMacawMessage, MacawMessage}; pub struct MessageSubscriptions { - all: HashMap<Uuid, mpsc::Sender<(BareJID, MacawMessage)>>, - subset: HashMap<BareJID, HashMap<Uuid, mpsc::Sender<MacawMessage>>>, + all: HashMap<Uuid, mpsc::Sender<(BareJID, ArcMacawMessage)>>, + subset: HashMap<BareJID, HashMap<Uuid, mpsc::Sender<ArcMacawMessage>>>, } impl MessageSubscriptions { @@ -19,7 +19,7 @@ impl MessageSubscriptions { } } - pub async fn broadcast(&mut self, to: BareJID, message: MacawMessage) { + pub async fn broadcast(&mut self, to: BareJID, message: ArcMacawMessage) { // subscriptions to all let mut removals = Vec::new(); for (id, sender) in &self.all { @@ -54,14 +54,14 @@ impl MessageSubscriptions { } } - pub fn subscribe_all(&mut self) -> (Uuid, Receiver<(BareJID, MacawMessage)>) { + pub fn subscribe_all(&mut self) -> (Uuid, Receiver<(BareJID, ArcMacawMessage)>) { let (send, recv) = mpsc::channel(10); let id = Uuid::new_v4(); self.all.insert(id, send); (id, recv) } - pub fn subscribe_chat(&mut self, chat: BareJID) -> (Uuid, Receiver<MacawMessage>) { + pub fn subscribe_chat(&mut self, chat: BareJID) -> (Uuid, Receiver<ArcMacawMessage>) { let (send, recv) = mpsc::channel(10); let id = Uuid::new_v4(); if let Some(chat_subscribers) = self.subset.get_mut(&chat) { |