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
use std::rc::Rc;
use crate::Token;
use crate::sources::EventDispatcher;
pub(crate) struct SourceList<Data> {
sources: Vec<Option<Rc<dyn EventDispatcher<Data>>>>,
}
impl<Data> SourceList<Data> {
pub(crate) fn new() -> SourceList<Data> {
SourceList {
sources: Vec::new(),
}
}
pub(crate) fn contains(&self, token: Token) -> bool {
self.sources
.get(token.id as usize)
.map(Option::is_some)
.unwrap_or(false)
}
pub(crate) fn get_dispatcher(&self, token: Token) -> Option<Rc<dyn EventDispatcher<Data>>> {
match self.sources.get(token.id as usize) {
Some(&Some(ref dispatcher)) => Some(dispatcher.clone()),
_ => None,
}
}
pub(crate) fn add_source(&mut self, dispatcher: Rc<dyn EventDispatcher<Data>>) -> Token {
let free_id = self.sources.iter().position(Option::is_none);
if let Some(id) = free_id {
self.sources[id] = Some(dispatcher);
Token {
id: id as u32,
sub_id: 0,
}
} else {
self.sources.push(Some(dispatcher));
Token {
id: (self.sources.len() - 1) as u32,
sub_id: 0,
}
}
}
pub(crate) fn del_source(&mut self, token: Token) -> Option<Rc<dyn EventDispatcher<Data>>> {
::std::mem::replace(&mut self.sources[token.id as usize], None)
}
}