rantz_proto 1.2.4

An opinionated rust library for transforming on-disk assets into Entities in Bevy.
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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84

use crate::prelude::*;
use bevy::{
    ecs::world::CommandQueue,
    prelude::*,
    tasks::{AsyncComputeTaskPool, Task},
};

#[derive(Component, Debug)]
pub(crate) struct ProtoSpawnTask(pub Task<CommandQueue>);

/// An extension trait for [`Commands`] [`CommandQueue`] and [`World`]
/// to allow direct spawning of prototypes
pub trait SpawnPrototypeExt {
    /// Spawns the given prototype
    fn spawn_prototype<P: Prototype>(&mut self, proto: P);
}

/// An extension trait for [`Commands`] [`CommandQueue`] and [`World`]
/// to allow direct spawning of prototypes in an async task
pub trait SpawnPrototypeAsyncExt {
    /// Spawns the given prototype in an async task
    fn spawn_prototype_async<P: Prototype>(&mut self, proto: P);
}

impl<'w, 's> SpawnPrototypeExt for Commands<'w, 's> {
    fn spawn_prototype<P: Prototype>(&mut self, proto: P) {
        let mut e = self.spawn_empty();

        #[cfg(feature = "hot_reload")]
        e.insert(FromPrototype(proto.id()));

        e.add(move |mut e: EntityWorldMut| proto.build(&mut e));
    }
}
impl<'w, 's> SpawnPrototypeAsyncExt for Commands<'w, 's> {
    fn spawn_prototype_async<P: Prototype>(&mut self, proto: P) {
        let thread_pool = AsyncComputeTaskPool::get();
        let task = thread_pool.spawn(async move {
            let mut queue = CommandQueue::default();
            queue.spawn_prototype(proto);
            queue
        });

        self.spawn_empty()
            .insert(ProtoSpawnTask(task))
            .insert(Name::new("Prototype Loading"));
    }
}

impl SpawnPrototypeExt for CommandQueue {
    fn spawn_prototype<P: Prototype>(&mut self, proto: P) {
        self.push(move |world: &mut World| {
            let mut target = world.spawn_empty();
            proto.build(&mut target);

            #[cfg(feature = "hot_reload")]
            target.insert(FromPrototype(proto.id()));
        });
    }
}

impl SpawnPrototypeExt for World {
    fn spawn_prototype<P: Prototype>(&mut self, proto: P) {
        let mut target = self.spawn_empty();
        proto.build(&mut target);

        #[cfg(feature = "hot_reload")]
        target.insert(FromPrototype(proto.id()));
    }
}
impl SpawnPrototypeAsyncExt for World {
    fn spawn_prototype_async<P: Prototype>(&mut self, proto: P) {
        let thread_pool = AsyncComputeTaskPool::get();
        let task = thread_pool.spawn(async move {
            let mut queue = CommandQueue::default();
            queue.spawn_prototype(proto);
            queue
        });

        self.spawn_empty()
            .insert(ProtoSpawnTask(task))
            .insert(Name::new("Prototype Loading"));
    }
}