eventsys 0.1.1

A library for dispatching and processing events. Events can be handled in a deferred and/or immediate way.
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
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117

use std::{collections::VecDeque, marker::PhantomData, sync::MutexGuard};

use crate::backend::Event;

#[derive(Debug)]
/// An iterator over events from type `T`.
pub struct Query<'a, T, const EVENT_SIZE: usize>
where
    T: 'static,
{
    events: MutexGuard<'a, VecDeque<Event<EVENT_SIZE>>>,

    _t: PhantomData<T>,
}

impl<'a, T, const EVENT_SIZE: usize> Query<'a, T, EVENT_SIZE>
where
    T: 'static,
{
    /// Creates a new `Query` to iterate over events from type `T`.
    #[inline]
    pub(crate) fn new(events: MutexGuard<'a, VecDeque<Event<EVENT_SIZE>>>) -> Self {
        Self {
            events,
            _t: PhantomData,
        }
    }

    #[inline]
    /// Returns the number of events this `Query` can produce.
    pub fn len(&self) -> usize {
        self.events.len()
    }
}

impl<'a, T, const EVENT_SIZE: usize> Iterator for Query<'a, T, EVENT_SIZE>
where
    T: 'static,
{
    type Item = T;

    #[inline]
    fn next(&mut self) -> Option<Self::Item> {
        let out = self.events.pop_front();

        out.map(Event::get)
    }
}

impl<'a, T, const EVENT_SIZE: usize> Drop for Query<'a, T, EVENT_SIZE>
where
    T: 'static,
{
    #[inline]
    fn drop(&mut self) {
        self.events.clear();
    }
}

// ############################
// ############################
// ############################

#[derive(Debug)]
/// An iterator over events from type `T`.
pub struct UnblockingQuery<T, const EVENT_SIZE: usize>
where
    T: 'static,
{
    events: VecDeque<Event<EVENT_SIZE>>,

    _t: PhantomData<T>,
}

impl<T, const EVENT_SIZE: usize> UnblockingQuery<T, EVENT_SIZE>
where
    T: 'static,
{
    #[inline]
    /// Creates a new `Query` to iterate over events from type `T`.
    pub(crate) fn new(events: VecDeque<Event<EVENT_SIZE>>) -> Self {
        Self {
            events,
            _t: PhantomData,
        }
    }

    #[inline]
    /// Returns the number of events this `Query` can produce.
    pub fn len(&self) -> usize {
        self.events.len()
    }
}

impl<T, const EVENT_SIZE: usize> Iterator for UnblockingQuery<T, EVENT_SIZE>
where
    T: 'static,
{
    type Item = T;

    #[inline]
    fn next(&mut self) -> Option<Self::Item> {
        let out = self.events.pop_front();

        out.map(Event::get)
    }
}

impl<T, const EVENT_SIZE: usize> Drop for UnblockingQuery<T, EVENT_SIZE>
where
    T: 'static,
{
    #[inline]
    fn drop(&mut self) {
        self.events.clear();
    }
}