fn remove_sink(&self, conn_uuid: u128) {
        // this should be our connection going away...
        if conn_uuid != self.session_id {
            log::warn!("producer {} asked to remove {}", self.session_id, conn_uuid);
            return;
        }
        self.mutable.lock().senders.iter().for_each(|s| {
            log::debug!("producer {} sending RemoveSink to coordinator", self.session_id);
            send_cmd(s, ChatCmd::RemoveSink(conn_uuid));
        });
    }
// remove a sink. This justs gets forwarded to the coordinator
remove a sink. This justs gets forwarded to the coordinator
remove a sink . This justs gets forwarded to the coordinator
fn remove_sink(&self, conn_uuid: u128) {
        // this should be our connection going away...
        if conn_uuid != self.session_id {
            log::warn!("producer {} asked to remove {}", self.session_id, conn_uuid);
            return;
        }
        self.mutable.lock().senders.iter().for_each(|s| {
            log::debug!("producer {} sending RemoveSink to coordinator", self.session_id);
            send_cmd(s, ChatCmd::RemoveSink(conn_uuid));
        });
    }
fn remove_sink ( & self , conn_uuid : u128 ) { // this should be our connection going away... if conn_uuid != self . session_id { log :: warn ! ( " " self session_id conn_uuid ) ; return ; } self . mutable . lock ( ) . senders . iter ( ) . for_each ( | s | { log :: debug ! ( " " self session_id ) ; send_cmd ( s , ChatCmd :: RemoveSink ( conn_uuid ) ) ; } ) ; }
remove a sink.
remove a sink .
&self
conn_uuid
u128