Struct backend::sse::broadcaster::Broadcaster

pub struct Broadcaster(Arc<Mutex<HashMap<i32, ConnectedMap>>>);

SSE broadcaster.

Inner HashMap:

• Map of map_id to a list of connected clients.
• The map_id is the id of the map that the client connected to.
• The connected map contains the map_id and a list of clients connected to that map.

Tuple Fields

0: Arc<Mutex<HashMap<i32, ConnectedMap>>>

Implementations

impl Broadcaster

pub fn new() -> Self

Constructs new broadcaster and spawns ping loop.

fn spawn_ping(self)

Pings clients every 10 minutes to see if they are alive and remove them from the broadcast list if not.

async fn remove_stale_clients(&self)

Removes all non-responsive clients from broadcast list. TODO: this is a naive implementation, we should probably use a better data structure for this. Things to consider: - how can we do this without having to iterate over all clients?

pub async fn new_client( &self, map_id: i32, ) -> Result<Sse<ChannelStream>, Box<dyn Error>>

Registers client with broadcaster, returning an SSE response body.

Errors

• If sender.send() fails for the new client.

pub async fn broadcast(&self, map_id: i32, action: Action)

Broadcasts msg to all clients on the same map.

pub async fn broadcast_all_maps(&self, action: Action)

Broadcasts msg to all clients on all maps.

Trait Implementations

impl Clone for Broadcaster

fn clone(&self) -> Broadcaster

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Broadcaster

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

Formats the value using the given formatter.

impl Default for Broadcaster

fn default() -> Broadcaster

Returns the “default value” for a type.