bevy_sorting 0.4.0

Sorting bevy systems based on reads and writes
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
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
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124

use std::sync::{Arc, Mutex};

use crate::prelude::*;
use bevy::prelude::*;

#[test]
fn reads_before_writes_test() {
    for _ in 0..8 {
        let trace = Arc::new(Mutex::new(Vec::<String>::new()));

        let mut app = App::new();

        let trace_handle = Arc::clone(&trace);
        app.add_systems(
            Startup,
            (move || {
                trace_handle.lock().unwrap().push("2".to_string());
            })
            .writes::<Marker>(),
        );

        let trace_handle = Arc::clone(&trace);
        app.add_systems(
            Startup,
            (move || {
                trace_handle.lock().unwrap().push("1".to_string());
            })
            .reads::<Marker>(),
        );

        app.configure_sets(Startup, read_before_write::<Marker>());

        app.run();

        assert_eq!(*trace.lock().unwrap(), vec!["1", "2"]);
    }
}
#[test]
fn writes_before_reads_test() {
    for _ in 0..8 {
        let trace = Arc::new(Mutex::new(Vec::<String>::new()));

        let mut app = App::new();

        let trace_handle = Arc::clone(&trace);
        app.add_systems(
            Startup,
            (move || {
                trace_handle.lock().unwrap().push("1".to_string());
            })
            .writes::<Marker>(),
        );

        let trace_handle = Arc::clone(&trace);
        app.add_systems(
            Startup,
            (move || {
                trace_handle.lock().unwrap().push("2".to_string());
            })
            .reads::<Marker>(),
        );

        app.configure_sets(Startup, write_before_read::<Marker>());

        app.run();

        assert_eq!(*trace.lock().unwrap(), vec!["1", "2"]);
    }
}

#[test]
fn with_resources() {
    for _ in 0..8 {
        let mut app = App::new();

        app.add_systems(
            Startup,
            (
                zero_to_res1.writes::<Res1>(),
                res1_to_res2a.reads::<Res1>().writes::<Res2a>(),
                res1_to_res2b.reads::<Res1>().writes::<Res2b>(),
                res2_to_res3.reads::<Res2a>().reads::<Res2b>(),
            ),
        )
        .configure_sets(
            Startup,
            (
                write_before_read::<Res1>(),
                write_before_read::<Res2a>(),
                write_before_read::<Res2b>(),
            ),
        );
        app.run();
    }
}

struct Marker;

#[derive(Resource)]
struct Res1;

#[derive(Resource)]
struct Res2a;

#[derive(Resource)]
struct Res2b;

#[derive(Resource)]
struct Res3;

fn zero_to_res1(mut commands: Commands) {
    commands.insert_resource(Res1);
}

fn res1_to_res2a(mut commands: Commands, _res1: Res<Res1>) {
    commands.insert_resource(Res2a);
}

fn res1_to_res2b(mut commands: Commands, _res1: Res<Res1>) {
    commands.insert_resource(Res2b);
}
fn res2_to_res3(mut commands: Commands, _res2a: Res<Res2a>, _res2b: Res<Res2b>) {
    commands.insert_resource(Res3);
}