nevy_messages 0.4.0

Structured messages for nevy
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

use bevy::{
    ecs::{intern::Interned, schedule::ScheduleLabel},
    prelude::*,
};
use nevy_transport::{DEFAULT_TRANSPORT_SCHEDULE, TransportUpdateSystems};

pub mod deserialize;
pub mod prelude;
pub mod protocol;
pub mod reader;
pub mod varint;
pub mod writer;

#[derive(SystemSet, Debug, Hash, PartialEq, Eq, Clone, Copy)]
pub enum MessageSystems {
    ReadStreams,
    DeserializeMessages,
}

pub struct NevyMessagesPlugin {
    schedule: Interned<dyn ScheduleLabel>,
}

impl NevyMessagesPlugin {
    pub fn new(schedule: impl ScheduleLabel) -> Self {
        NevyMessagesPlugin {
            schedule: schedule.intern(),
        }
    }
}

impl Default for NevyMessagesPlugin {
    fn default() -> Self {
        Self::new(DEFAULT_TRANSPORT_SCHEDULE)
    }
}

impl Plugin for NevyMessagesPlugin {
    fn build(&self, app: &mut App) {
        app.insert_resource(NevyMessagesSchedule(self.schedule));

        app.configure_sets(
            self.schedule,
            (
                TransportUpdateSystems,
                MessageSystems::ReadStreams,
                MessageSystems::DeserializeMessages,
            )
                .chain(),
        );

        app.add_systems(
            self.schedule,
            (reader::accept_streams, reader::read_streams)
                .chain()
                .in_set(MessageSystems::ReadStreams),
        );
    }
}

#[derive(Resource, Deref)]
struct NevyMessagesSchedule(Interned<dyn ScheduleLabel>);