fn create_instance(&self, conn_uuid: u128, any_sender: AnySender) {
        if let Ok(session_sender) = Arc::clone(&any_sender).downcast::<Sender<ChatCmd>>() {
            let (_instance, sender) = executor::connect(ChatInstance::new(conn_uuid));
            send_cmd(&session_sender, ChatCmd::Instance(conn_uuid, sender, "ChatProducer".to_string()));
        } else {
            log::warn!("echo producer component received an unknown sender");
        }
    }
// create a producer for the new connection
create a producer for the new connection
create a producer for the new connection
fn create_instance(&self, conn_uuid: u128, any_sender: AnySender) {
        if let Ok(session_sender) = Arc::clone(&any_sender).downcast::<Sender<ChatCmd>>() {
            let (_instance, sender) = executor::connect(ChatInstance::new(conn_uuid));
            send_cmd(&session_sender, ChatCmd::Instance(conn_uuid, sender, "ChatProducer".to_string()));
        } else {
            log::warn!("echo producer component received an unknown sender");
        }
    }
fn create_instance ( & self , conn_uuid : u128 , any_sender : AnySender ) { if let Ok ( session_sender ) = Arc :: clone ( & any_sender ) . downcast :: < Sender < ChatCmd > > ( ) { let ( _instance , sender ) = executor :: connect ( ChatInstance :: new ( conn_uuid ) ) ; send_cmd ( & session_sender , ChatCmd :: Instance ( conn_uuid , sender , " " . to_string ( ) ) ) ; } else { log :: warn ! ( " " ) ; } }
create a producer for the new connection
create a producer for the new connection
&self
conn_uuid
u128
any_sender
AnySender