Struct PhysicsStreamServer 

pub struct PhysicsStreamServer {
    pub port: u16,
    pub n_clients: usize,
    pub frame_queue: VecDeque<ProtocolFrame>,
    pub protocol: BinaryProtocol,
    pub running: bool,
    /* private fields */
}

Mock physics stream server.

Serves physics state frames to connected mock clients.

Fields

port: u16

Port (mock).

n_clients: usize

Number of connected clients.

frame_queue: VecDeque<ProtocolFrame>

Frame queue for broadcasting.

protocol: BinaryProtocol

Protocol encoder.

running: bool

Running flag.

Implementations

impl PhysicsStreamServer

pub fn new(port: u16) -> Self

Create a new physics stream server.

pub fn start(&mut self)

Start serving.

pub fn stop(&mut self)

Stop serving.

pub fn connect_client(&mut self)

Connect a mock client.

pub fn disconnect_client(&mut self)

Disconnect a mock client.

pub fn broadcast(&mut self, timestamp: f64, state: Vec<u8>)

Broadcast physics state to all clients.

pub fn pop_frame(&mut self) -> Option<ProtocolFrame>

Get next frame from queue.

pub fn queue_depth(&self) -> usize

Queue depth.

Trait Implementations

impl Debug for PhysicsStreamServer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.