lgui-core 0.2.0

Platform-neutral runtime and UI primitives for LGUI
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

use std::sync::{Arc, Weak};

use super::bus::EventBusInner;

pub struct EventSubscription {
    bus: Weak<EventBusInner>,
    key: Arc<str>,
    id: u64,
}

impl EventSubscription {
    pub(super) fn new(bus: &Arc<EventBusInner>, key: Arc<str>, id: u64) -> Self {
        Self {
            bus: Arc::downgrade(bus),
            key,
            id,
        }
    }
}

impl Drop for EventSubscription {
    fn drop(&mut self) {
        let Some(bus) = self.bus.upgrade() else {
            return;
        };
        let mut topics = bus.topics.lock().expect("event bus poisoned");
        let remove_topic = topics.get_mut(self.key.as_ref()).is_some_and(|topic| {
            topic.listeners.remove(&self.id);
            topic.listeners.is_empty()
        });
        if remove_topic {
            topics.remove(self.key.as_ref());
        }
    }
}