mundy 0.2.3

Reads various system-level accessibility and UI preferences
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
35
36
37
38
39
40
41
42
43
44
45
46
47
48

#[cfg(any(feature = "callback", target_os = "linux"))]
cfg_if::cfg_if! {
    if #[cfg(all(feature = "tokio", target_os = "linux"))] {
        #[allow(dead_code)]
        pub(crate) fn block_on<F>(future: F) -> F::Output
            where F: std::future::Future
        {
            // These are the features that zbus also activates:
            // <https://github.com/dbus2/zbus/blob/4e4151a9f9d745803d0337e1cd73e2b0f8eaec0d/zbus/src/utils.rs#L39>
            let runtime = tokio::runtime::Builder::new_current_thread()
                .enable_io()
                .enable_time()
                .build()
                .expect("launch of single-threaded tokio runtime");
            runtime.block_on(future)
        }
    } else if #[cfg(all(feature = "async-io", target_os = "linux"))] {
        #[allow(dead_code)]
        pub(crate) fn block_on<F>(future: F) -> F::Output
            where F: std::future::Future
        {
            async_io::block_on(future)
        }
    } else if #[cfg(not(all(target_family = "wasm", target_os = "unknown")))] {
        #[allow(dead_code)]
        pub(crate) fn block_on<F>(future: F) -> F::Output
            where F: std::future::Future
        {
            beul::execute(future)
        }
    }
}

#[cfg(feature = "callback")]
cfg_if::cfg_if! {
    if #[cfg(all(target_family = "wasm", target_os = "unknown"))] {
        pub(crate) fn spawn_future(future: impl std::future::Future<Output = ()> + Send + 'static) {
            wasm_bindgen_futures::spawn_local(future);
        }
    } else {
        pub(crate) fn spawn_future(future: impl std::future::Future<Output = ()> + Send + 'static) {
            std::thread::Builder::new()
                .name(format!("{} subscription thread", env!("CARGO_PKG_NAME")))
                .spawn(move || block_on(future))
                .expect("failed to spawn thread");
        }
    }
}