bevy_sync 0.19.0

Plugin for synchronizing entities and components between server and its clients.
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

use bevy_app::prelude::*;
use bevy_connect::prelude::*;
use bevy_ecs::prelude::*;

use crate::{networking::assets::AssetMessage, SyncStats};

pub(crate) struct MetricsPlugin;

impl Plugin for MetricsPlugin {
    fn build(&self, app: &mut App) {
        app.init_resource::<SyncStats>();
        app.add_systems(Update, update_stats);
    }
}

fn update_stats(
    mut stats: ResMut<SyncStats>,
    syncs: Option<Res<Channel<crate::proto::Message>>>,
    assets: Option<Res<Channel<AssetMessage>>>,
) {
    if let Some(syncs) = syncs {
        let r = syncs.total_read();
        let s = syncs.total_sent();
        if stats.total_sync_net_read_prev < r {
            stats.total_sync_net_read += r.saturating_sub(stats.total_sync_net_read_prev);
        }
        if stats.total_sync_net_sent_prev < s {
            stats.total_sync_net_sent += s.saturating_sub(stats.total_sync_net_sent_prev);
        }
        stats.total_sync_net_read_prev = r;
        stats.total_sync_net_sent_prev = s;
    }
    if let Some(assets) = assets {
        let r = assets.total_read();
        let s = assets.total_sent();
        if stats.total_asset_net_read_prev < r {
            stats.total_asset_net_read += r.saturating_sub(stats.total_sync_net_read_prev);
        }
        if stats.total_asset_net_sent_prev < s {
            stats.total_asset_net_sent += s.saturating_sub(stats.total_sync_net_sent_prev);
        }
        stats.total_asset_net_read_prev = r;
        stats.total_asset_net_sent_prev = s;
    }
}