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
|
use std::any::Any;
use crate::lock::WriteGuard;
use crate::system::{
NoInitParamFlag as NoInitSystemParamFlag,
Param as SystemParam,
System,
};
use crate::tuple::FilterExclude as TupleFilterExclude;
use crate::{WorldData, WorldFlags};
#[derive(Debug)]
pub struct Flags<'world>
{
world_flags: WriteGuard<'world, WorldFlags>,
}
impl<'world> Flags<'world>
{
/// Calling this function makes the loop in [`Engine::event_loop`] stop at the next
/// opportune time.
pub fn stop(&mut self)
{
self.world_flags.stop = true;
}
}
unsafe impl<'world> SystemParam<'world> for Flags<'world>
{
type Flags = NoInitSystemParamFlag;
type Input = TupleFilterExclude;
fn initialize<SystemImpl>(
_system: &mut impl System<'world, SystemImpl>,
_input: Self::Input,
)
{
}
fn new<SystemImpl>(
_system: &'world impl System<'world, SystemImpl>,
world_data: &'world WorldData,
) -> Self
{
Self {
world_flags: world_data
.flags
.write_nonblock()
.expect("Failed to acquire read-write world flags lock"),
}
}
fn is_compatible<Other: SystemParam<'world>>() -> bool
{
let other_comparable = Other::get_comparable();
other_comparable.downcast_ref::<Comparable>().is_none()
}
fn get_comparable() -> Box<dyn Any>
{
Box::new(Comparable)
}
}
struct Comparable;
|