naia-client-socket 0.25.0

Abstraction to expose common API over a UDP socket on Linux, and a unreliable WebRTC datachannel on the browser
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

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

use crate::{
    error::NaiaClientSocketError, packet_receiver::PacketReceiver, server_addr::ServerAddr,
};

use super::{addr_cell::AddrCell, data_port::DataPort};

/// Handles receiving messages from the Server through a given Client Socket
#[derive(Clone)]
pub struct PacketReceiverImpl {
    message_queue: Arc<Mutex<VecDeque<Box<[u8]>>>>,
    server_addr: AddrCell,
    last_payload: Option<Box<[u8]>>,
}

impl PacketReceiverImpl {
    /// Create a new PacketReceiver, if supplied with the RtcDataChannel and a
    /// reference to a list of dropped messages
    pub fn new(data_port: &DataPort, addr_cell: &AddrCell) -> Self {
        Self {
            message_queue: data_port.message_queue(),
            server_addr: addr_cell.clone(),
            last_payload: None,
        }
    }
}

impl PacketReceiver for PacketReceiverImpl {
    fn receive(&mut self) -> Result<Option<&[u8]>, NaiaClientSocketError> {
        match self
            .message_queue
            .lock()
            .expect("This should never happen, message_queue should always be available in a single-threaded context")
            .pop_front()
        {
            Some(payload) => {
                self.last_payload = Some(payload);
                Ok(Some(self.last_payload.as_ref().unwrap()))
            }
            None => Ok(None),
        }
    }

    /// Get the Server's Socket address
    fn server_addr(&self) -> ServerAddr {
        self.server_addr.get()
    }
}