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
31
32
33
34

use super::connection::Connection;
use futures::channel::oneshot::Sender;
use std::collections::HashSet;
use std::ops::Deref;

impl Connection {
    pub(super) fn list_path(&mut self, path: &str, sender: Sender<HashSet<String>>) {
        // List the handler.
        let mut result = HashSet::new();

        let path_with_slash = if path == "/" {
            path.to_string()
        } else {
            format!("{}/", path)
        };

        let split_at = path_with_slash.len();
        for p in self.path_handler.keys() {
            if p.deref() == path {
                continue;
            } else if p.starts_with(&path_with_slash) {
                let (_, last) = p.split_at(split_at);
                let base: Vec<&str> = last.splitn(2, '/').collect();
                if let Some(base) = base.get(0) {
                    result.insert(base.to_string());
                }
            }
        }

        if let Err(e) = sender.send(result) {
            error!("ListPath: cannot send result: {:?}", e);
        }
    }
}