fn remove_sink(&self, conn_uuid: u128) {
        let mut mutable = self.mutable.lock();
        // it its our connection, let the producer know
        if conn_uuid == self.session_id {
            if let Some(sender) = &mutable.sender_producer {
                // tell our producer, who we've otherwise never spoken with...
                send_cmd(sender, ChatCmd::RemoveSink(conn_uuid));
            }
        } else {
            // otherwise, stop forwarding to it
            log::debug!("consumer {} removed producer {}", self.session_id, conn_uuid);
            mutable.senders.remove(&conn_uuid);
        }
    }
// remove a sink, which is a producer's sender
remove a sink, which is a producer's sender
remove a sink which is a producer ' s sender
fn remove_sink(&self, conn_uuid: u128) {
        let mut mutable = self.mutable.lock();
        // it its our connection, let the producer know
        if conn_uuid == self.session_id {
            if let Some(sender) = &mutable.sender_producer {
                // tell our producer, who we've otherwise never spoken with...
                send_cmd(sender, ChatCmd::RemoveSink(conn_uuid));
            }
        } else {
            // otherwise, stop forwarding to it
            log::debug!("consumer {} removed producer {}", self.session_id, conn_uuid);
            mutable.senders.remove(&conn_uuid);
        }
    }
fn remove_sink ( & self , conn_uuid : u128 ) { let mut mutable = self . mutable . lock ( ) ; // it its our connection, let the producer know if conn_uuid == self . session_id { if let Some ( sender ) = & mutable . sender_producer { // tell our producer, who we've otherwise never spoken with... send_cmd ( sender , ChatCmd :: RemoveSink ( conn_uuid ) ) ; } } else { // otherwise, stop forwarding to it log :: debug ! ( " " self session_id conn_uuid ) ; mutable . senders . remove ( & conn_uuid ) ; } }
remove a sink, which is a producer's sender
remove a sink which is a producer ' s sender
&self
conn_uuid
u128