Struct Router 

pub struct Router { /* private fields */ }

Router-State.

Implementations

impl Router

pub fn new() -> Self

Konstruktor.

pub fn register_connection(&mut self, id: u64, sender: Sender<RouterMsg>)

Registriert eine neue Connection.

pub fn deregister_connection(&mut self, id: u64)

Entfernt eine Connection (cleanup beim Disconnect).

pub fn subscribe(&mut self, conn_id: u64, topic: String)

Subscribiert eine Connection auf ein Topic.

pub fn unsubscribe(&mut self, conn_id: u64, topic: &str)

Unsubscribe.

pub fn dispatch(&mut self, topic: &str, payload: Vec<u8>) -> usize

Pusht ein Sample an alle Subscriber. Connections deren channel disconnected ist werden automatisch entfernt (lazy cleanup).

pub fn broadcast_shutdown(&self)

Sendet Shutdown an alle Connections (graceful drain).

pub fn connection_count(&self) -> usize

Anzahl aktiver Connections.

Trait Implementations

impl Debug for Router

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

Formats the value using the given formatter.

impl Default for Router

fn default() -> Router

Returns the “default value” for a type.