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

use crate::events::SocketRecvEvent;
use bevy::prelude::*;
use bevy_matchbox::{prelude::MultipleChannels, MatchboxSocket};

/// A type alias to the underlying matchbox socket.
pub type RtcSocket = MatchboxSocket<RtcSocketPlurality>;
/// A type alias to the underlying matchbox socket plurality.
pub type RtcSocketPlurality = MultipleChannels;

/// The index of the unreliable channel in the [`WebRtcSocket`].
pub const UNRELIABLE_CHANNEL_INDEX: usize = 0;
/// The index of the reliable channel in the [`WebRtcSocket`].
pub const RELIABLE_CHANNEL_INDEX: usize = 1;

pub fn common_socket_reader(
    mut socket: ResMut<RtcSocket>,
    mut event_wtr: EventWriter<SocketRecvEvent>,
) {
    let messages = socket
        .channel_mut(RELIABLE_CHANNEL_INDEX)
        .receive()
        .into_iter()
        .chain(socket.channel_mut(UNRELIABLE_CHANNEL_INDEX).receive())
        .map(SocketRecvEvent)
        .collect::<Vec<_>>();
    trace!("Received {} total messages", messages.len());

    event_wtr.send_batch(messages);
}