fn add_consumer(&self, conn_uuid: u128, sender: ChatSender) {
        let mut mutable = self.mutable.lock();
        for (k, v) in &mutable.producers {
            send_cmd(&sender, ChatCmd::AddSink(*k, v.clone()));
        }
        mutable.consumers.insert(conn_uuid, sender);
    }
// a new consumer gets connected to all producers
a new consumer gets connected to all producers
a new consumer gets connected to all producers
fn add_consumer(&self, conn_uuid: u128, sender: ChatSender) {
        let mut mutable = self.mutable.lock();
        for (k, v) in &mutable.producers {
            send_cmd(&sender, ChatCmd::AddSink(*k, v.clone()));
        }
        mutable.consumers.insert(conn_uuid, sender);
    }
fn add_consumer ( & self , conn_uuid : u128 , sender : ChatSender ) { let mut mutable = self . mutable . lock ( ) ; for ( k , v ) in & mutable . producers { send_cmd ( & sender , ChatCmd :: AddSink ( * k , v . clone ( ) ) ) ; } mutable . consumers . insert ( conn_uuid , sender ) ; }
a new consumer gets connected to all producers
a new consumer gets connected to all producers
&self
conn_uuid
u128
sender
ChatSender