dbus-async 1.1.0

Asynchronous DBus library
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

use super::super::connection::Connection;
use dbus_message_parser::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.
        if let Some(path) = msg.get_path() {
            // A valid `Signal` needs to have an `Interface` and a `Member`.
            if msg.has_interface() && msg.has_member() {
                let path = path.to_string();
                // 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 |sender| {
                        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);
                }
            }
        }
    }
}