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
use std::{cell::RefCell, collections::VecDeque, rc::Rc};
pub struct DispatchData<'a> {
data: &'a mut dyn std::any::Any,
}
impl<'a> std::fmt::Debug for DispatchData<'a> {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
f.write_str("DispatchData { ... }")
}
}
impl<'a> DispatchData<'a> {
pub fn get<T: std::any::Any>(&mut self) -> Option<&mut T> {
self.data.downcast_mut()
}
pub fn wrap<T: std::any::Any>(data: &'a mut T) -> DispatchData<'a> {
DispatchData { data }
}
pub fn reborrow(&mut self) -> DispatchData {
DispatchData { data: &mut *self.data }
}
}
struct Inner<E, F: ?Sized> {
pending: RefCell<VecDeque<E>>,
cb: RefCell<F>,
}
type DynInner<E> = Inner<E, dyn FnMut(E, &Filter<E>, DispatchData<'_>)>;
pub struct Filter<E> {
inner: Rc<DynInner<E>>,
}
impl<E: std::fmt::Debug> std::fmt::Debug for Filter<E> {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
f.debug_struct("Filter").field("pending", &self.inner.pending).finish()
}
}
impl<E> Clone for Filter<E> {
fn clone(&self) -> Filter<E> {
Filter { inner: self.inner.clone() }
}
}
impl<E> Filter<E> {
pub fn new<F: FnMut(E, &Filter<E>, DispatchData<'_>) + 'static>(f: F) -> Filter<E> {
Filter {
inner: Rc::new(Inner { pending: RefCell::new(VecDeque::new()), cb: RefCell::new(f) }),
}
}
pub fn send(&self, evt: E, mut data: DispatchData) {
if let Ok(mut guard) = self.inner.cb.try_borrow_mut() {
(&mut *guard)(evt, self, data.reborrow());
while let Some(evt) = self.inner.pending.borrow_mut().pop_front() {
(&mut *guard)(evt, self, data.reborrow());
}
} else {
self.inner.pending.borrow_mut().push_back(evt);
}
}
}