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

use crate::{async_rt, Interest, Preferences};
use futures_channel::oneshot;
use futures_lite::{stream, StreamExt as _};

pub trait CallbackFn: FnMut(Preferences) + Send + Sync + 'static {}

impl<F> CallbackFn for F where F: FnMut(Preferences) + Send + Sync + 'static {}

/// A subscription for preferences created using [`Preferences::subscribe()`].
/// Dropping the subscription will cancel it and clean up all associated resources.
pub struct Subscription(
    #[expect(dead_code, reason = "only used to send a canceled message on drop")]
    Option<oneshot::Sender<()>>,
);

#[cfg(test)]
static_assertions::assert_impl_all!(Subscription: Send, Sync);

impl Preferences {
    pub(crate) fn subscribe_impl(
        interest: Interest,
        mut callback: impl CallbackFn,
    ) -> Subscription {
        // No need to spawn a thread if the interests are empty.
        if interest.is_empty() {
            return Subscription(None);
        }
        let (sender, receiver) = oneshot::channel();
        let mut stream = Self::stream(interest)
            .map(Message::Preferences)
            .race(stream::once_future(receiver).map(|_| Message::Shutdown));
        async_rt::spawn_future(async move {
            while let Some(message) = stream.next().await {
                match message {
                    Message::Preferences(preferences) => callback(preferences),
                    Message::Shutdown => break,
                }
            }
        });
        Subscription(Some(sender))
    }
}

enum Message {
    Preferences(Preferences),
    Shutdown,
}