jay-compositor 1.15.0

The Jay compositor
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
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65

use crate::state::State;
use crate::utils::event_listener::EventSource;
use crate::utils::queue::AsyncQueue;
use std::cell::Cell;
use std::ops::Deref;
use std::rc::Rc;

pub async fn handle_lazy_event_sources(state: Rc<State>) {
    loop {
        let source = state.lazy_event_sources.queue.pop().await;
        source.queued.set(false);
        source.listeners.for_each(|listener| {
            listener.triggered();
        });
    }
}

#[derive(Default)]
pub struct LazyEventSources {
    queue: AsyncQueue<Rc<LazyEventSource>>,
}

pub trait LazyEventSourceListener {
    fn triggered(self: Rc<Self>);
}

pub struct LazyEventSource {
    sources: Rc<LazyEventSources>,
    queued: Cell<bool>,
    listeners: EventSource<dyn LazyEventSourceListener>,
}

impl Deref for LazyEventSource {
    type Target = EventSource<dyn LazyEventSourceListener>;

    fn deref(&self) -> &Self::Target {
        &self.listeners
    }
}

impl LazyEventSource {
    pub fn trigger(self: &Rc<Self>) {
        if self.listeners.is_empty() {
            return;
        }
        if self.queued.replace(true) {
            return;
        }
        self.sources.queue.push(self.clone());
    }
}

impl LazyEventSources {
    pub fn create_source(self: &Rc<Self>) -> Rc<LazyEventSource> {
        Rc::new(LazyEventSource {
            sources: self.clone(),
            queued: Default::default(),
            listeners: Default::default(),
        })
    }

    pub fn clear(&self) {
        self.queue.clear();
    }
}