pub async fn send(&mut self, log_msg: &Message) {
        join_all(self.listeners.iter_mut().map(|listener| listener.send_log(log_msg.clone())))
            .await;
        self.listeners.retain(Listener::is_healthy);
    }
/// Sends the provided log message to all listeners in the pool. Removes listeners that become
/// stale.
///
/// Each message is sent concurrently to all listeners, and the function returns when all
/// listeners have acknowledged receipt of the message.
Sends the provided log message to all listeners in the pool. Removes listeners that become
stale.

Each message is sent concurrently to all listeners, and the function returns when all
listeners have acknowledged receipt of the message.
Sends the provided log message to all listeners in the pool . Removes listeners that become stale . Each message is sent concurrently to all listeners and the function returns when all listeners have acknowledged receipt of the message .
pub async fn send(&mut self, log_msg: &Message) {
        join_all(self.listeners.iter_mut().map(|listener| listener.send_log(log_msg.clone())))
            .await;
        self.listeners.retain(Listener::is_healthy);
    }
pub async fn send ( & mut self , log_msg : & Message ) { join_all ( self . listeners . iter_mut ( ) . map ( | listener | listener . send_log ( log_msg . clone ( ) ) ) ) . await ; self . listeners . retain ( Listener :: is_healthy ) ; }
Sends the provided log message to all listeners in the pool.
Sends the provided log message to all listeners in the pool .
&mut self
log_msg
&Message
&mut self
log_msg
&Message