fn new_data(&self, conn_uuid: u128, bytes: &Data) {
        self.mutable.lock().senders.iter().for_each(|s| {
            log::debug!("consumer {} sending to {}", self.session_id, s.0);
            send_cmd(s.1, ChatCmd::NewData(conn_uuid, Arc::clone(bytes)));
        });
    }
// a new message arrived, forward it to saved producers
a new message arrived, forward it to saved producers
a new message arrived forward it to saved producers
fn new_data(&self, conn_uuid: u128, bytes: &Data) {
        self.mutable.lock().senders.iter().for_each(|s| {
            log::debug!("consumer {} sending to {}", self.session_id, s.0);
            send_cmd(s.1, ChatCmd::NewData(conn_uuid, Arc::clone(bytes)));
        });
    }
fn new_data ( & self , conn_uuid : u128 , bytes : & Data ) { self . mutable . lock ( ) . senders . iter ( ) . for_each ( | s | { log :: debug ! ( " " self session_id s 0 ) ; send_cmd ( s . 1 , ChatCmd :: NewData ( conn_uuid , Arc :: clone ( bytes ) ) ) ; } ) ; }
a new message arrived, forward it to saved producers
a new message arrived forward it to saved producers
&self
conn_uuid
u128
bytes
&Data