bevy_rtc 0.3.1

A client-server library designed over WebRTC for 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

use crate::{events::SocketRecvEvent, protocol::Protocol};
use bevy::prelude::*;
use std::collections::VecDeque;

#[derive(Default, Debug, Resource)]
pub struct IncomingMessages<M: Protocol> {
    pub bound: usize,
    pub messages: VecDeque<M>,
}

impl<M: Protocol> IncomingMessages<M> {
    pub fn receive_payloads(mut incoming: ResMut<Self>, mut events: EventReader<SocketRecvEvent>) {
        let bound = incoming.bound;
        let packets: Vec<_> = events
            .read()
            .map(|&SocketRecvEvent((_peer_id, ref packet))| packet)
            .filter_map(M::from_packet)
            .enumerate()
            .take_while(|(read, _)| *read <= bound)
            .map(|(_, packet)| packet)
            .collect();
        trace!("Read {} {} packets", packets.len(), M::reflect_name());
        for packet in packets.into_iter() {
            incoming.messages.push_back(packet);
        }
        if incoming.messages.len() > bound {
            warn!(
                "The `{}` protocol is overflowing its bounded buffer ({bound}) and dropping packets! Is it being read?",
                M::reflect_name()
            );
            while incoming.messages.len() > bound {
                incoming.messages.pop_front();
            }
        }
    }
}