dbus-async 2.3.1

use super::super::Connection;
use dbus_message_parser::message::Message;
use retain_mut::RetainMut;

impl Connection {
    pub(super) fn signal(&mut self, msg: Message) {
        // It is a Signal so we have to get the Path first.
        let path = msg.get_path().unwrap();
        // Try to get the signal handler
        if let Some(list) = self.signals.get_mut(path) {
            // Go through the list and try to send the signal.
            list.retain_mut(move |(filter, sender)| {
                if let Some(filter) = filter {
                    if filter(&msg) {
                        return true;
                    }
                }
                if let Err(e) = sender.try_send(msg.clone()) {
                    if e.is_disconnected() {
                        // The handler is closed so remove it from the list.
                        return false;
                    }
                }
                true
            });
        } else {
            debug!("Signal: UNHANDLED: {:?}", msg);
        }
    }
}