fn remove_sink(&self, conn_uuid: u128) {
        // we've come full circle from where we told the consumers that the connection is closed.
        log::debug!("coordinator is dropping name, consumer and producer for connection {}", conn_uuid);
        let mut mutable = self.mutable.lock();
        mutable.names.remove(&conn_uuid);
        mutable.producers.remove(&conn_uuid);
        mutable.consumers.remove(&conn_uuid);
    }
// final removal of the connection, this will cause the consumer and producer to die as well
final removal of the connection, this will cause the consumer and producer to die as well
final removal of the connection this will cause the consumer and producer to die as well
fn remove_sink(&self, conn_uuid: u128) {
        // we've come full circle from where we told the consumers that the connection is closed.
        log::debug!("coordinator is dropping name, consumer and producer for connection {}", conn_uuid);
        let mut mutable = self.mutable.lock();
        mutable.names.remove(&conn_uuid);
        mutable.producers.remove(&conn_uuid);
        mutable.consumers.remove(&conn_uuid);
    }
fn remove_sink ( & self , conn_uuid : u128 ) { // we've come full circle from where we told the consumers that the connection is closed. log :: debug ! ( " " conn_uuid ) ; let mut mutable = self . mutable . lock ( ) ; mutable . names . remove ( & conn_uuid ) ; mutable . producers . remove ( & conn_uuid ) ; mutable . consumers . remove ( & conn_uuid ) ; }
final removal of the connection, this will cause the consumer and producer to die as well
final removal of the connection this will cause the consumer and producer to die as well
&self
conn_uuid
u128