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
use std::rc::Rc;
use crate::simulation::observable::*;
#[must_use = "computations are lazy and do nothing unless to be run"]
#[derive(Clone)]
pub struct ObservableFn<T> {
gen: Rc<dyn Fn() -> ObservableBox<T>>
}
impl<T> ObservableFn<T> {
#[inline]
pub fn new<F, O>(f: F) -> Self
where F: Fn() -> O + 'static,
O: Observable<Message = T> + 'static
{
ObservableFn {
gen: Rc::new(move || { f().into_boxed() })
}
}
#[inline]
pub fn next(&self) -> ObservableBox<T> {
(self.gen)()
}
}