async-ecs 0.1.0

Async Parallel Entity Component System for Rust
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
62
63
64

use std::ops::Deref;

use futures::future::BoxFuture;

use crate::{
    system::{AsyncSystem, DynamicSystemData, System},
    world::World,
};

pub type ThreadRun = Box<dyn for<'a> Run<'a> + Send>;
pub type LocalRun = Box<dyn for<'a> Run<'a>>;

pub type ThreadRunAsync = Box<dyn for<'a> RunAsync<'a> + Send>;
pub type LocalRunAsync = Box<dyn for<'a> RunAsync<'a>>;

/// Trait for fetching data and running systems.
/// Automatically implemented for systems.
pub trait Run<'a> {
    /// Runs the system now.
    ///
    /// # Panics
    ///
    /// Panics if the system tries to fetch resources
    /// which are borrowed in an incompatible way already
    /// (tries to read from a resource which is already written to or
    /// tries to write to a resource which is read from).
    fn run(&mut self, world: &'a World);
}

impl<'a, T> Run<'a> for T
where
    T: System<'a>,
{
    fn run(&mut self, world: &'a World) {
        let data = T::SystemData::fetch(self.accessor().deref(), world);

        self.run(data)
    }
}

/// Trait for fetching data and running systems with async/await.
/// Automatically implemented for systems.
pub trait RunAsync<'a> {
    /// Runs the system now.
    ///
    /// # Panics
    ///
    /// Panics if the system tries to fetch resources
    /// which are borrowed in an incompatible way already
    /// (tries to read from a resource which is already written to or
    /// tries to write to a resource which is read from).
    fn run(&mut self, world: &'a World) -> BoxFuture<'a, ()>;
}

impl<'a, T> RunAsync<'a> for T
where
    T: AsyncSystem<'a>,
{
    fn run(&mut self, world: &'a World) -> BoxFuture<'a, ()> {
        let data = T::SystemData::fetch(self.accessor().deref(), world);

        self.run_async(data)
    }
}