calloop 0.4.4

A callback-based event loop
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

use std::cell::RefCell;
use std::rc::Rc;

use mio::Token;

use sources::EventDispatcher;

pub(crate) struct SourceList<Data> {
    sources: Vec<Option<Rc<RefCell<EventDispatcher<Data>>>>>,
}

impl<Data> SourceList<Data> {
    pub(crate) fn new() -> SourceList<Data> {
        SourceList {
            sources: Vec::new(),
        }
    }

    pub(crate) fn get_dispatcher(
        &self,
        token: Token,
    ) -> Option<Rc<RefCell<EventDispatcher<Data>>>> {
        match self.sources.get(token.0) {
            Some(&Some(ref dispatcher)) => Some(dispatcher.clone()),
            _ => None,
        }
    }

    pub(crate) fn add_source(&mut self, dispatcher: Rc<RefCell<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)
        } else {
            self.sources.push(Some(dispatcher));
            Token(self.sources.len() - 1)
        }
    }

    // this method returns the removed dispatcher to ensure it is not dropped
    // while the refcell containing the list is borrowed, as dropping a dispatcher
    // can trigger the removal of an other source
    pub(crate) fn del_source(
        &mut self,
        token: Token,
    ) -> Option<Rc<RefCell<EventDispatcher<Data>>>> {
        ::std::mem::replace(&mut self.sources[token.0], None)
    }
}

pub(crate) trait ErasedList {
    // this returs a value for the same reason as above, but we must erase its type
    // due to the `Data` parameter, hence Box<Any>
    fn del_source(&mut self, token: Token) -> Box<::std::any::Any>;
}

impl<Data: 'static> ErasedList for SourceList<Data> {
    fn del_source(&mut self, token: Token) -> Box<::std::any::Any> {
        Box::new(self.del_source(token))
    }
}