pub async fn run(self) -> Result<(), Error> {
        let mut incoming_messages = self.chat_service.incoming(self.config.alias);

        while let Some(Ok(message)) = StreamExt::next(&mut incoming_messages).await {
            for route in &self.routes {
                route.call(self.chat_service.clone(), &message, self.store.clone()).await?
            }
        }

        Ok(())
    }
/// Starts the robot, connecting to the chat service and listening for incoming messages.
Starts the robot, connecting to the chat service and listening for incoming messages.
Starts the robot connecting to the chat service and listening for incoming messages .
pub async fn run(self) -> Result<(), Error> {
        let mut incoming_messages = self.chat_service.incoming(self.config.alias);
        while let Some(Ok(message)) = StreamExt::next(&mut incoming_messages).await {
            for route in &self.routes {
                route.call(self.chat_service.clone(), &message, self.store.clone()).await?
            }
        }
        Ok(())
    }
pub async fn run ( self ) -> Result < ( ) , Error > { let mut incoming_messages = self . chat_service . incoming ( self . config . alias ) ; while let Some ( Ok ( message ) ) = StreamExt :: next ( & mut incoming_messages ) . await { for route in & self . routes { route . call ( self . chat_service . clone ( ) , & message , self . store . clone ( ) ) . await ? } } Ok ( ( ) ) }
Starts the robot, connecting to the chat service and listening for incoming messages.
Starts the robot connecting to the chat service and listening for incoming messages .
self
self