Struct psrt::ServerClientDB

pub struct ServerClientDB { /* fields omitted */ }

Implementations

impl ServerClientDB

pub async fn register_data_channel(
    &mut self,
    token: &Token,
    channel: Sender<Arc<MessageFrame>>
) -> Result<(Sender<Arc<MessageFrame>>, ServerClient), Error>

Errors

Will return Err if the token is not registered

pub fn get_stats(&self) -> ServerClientDBStats

pub fn register_client(&mut self, login: &str) -> ServerClient

pub fn unregister_client(&mut self, client: &ServerClient)

pub fn subscribe(
    &mut self,
    topic: &str,
    client: ServerClient
) -> Result<(), Error>

Errors

With return Err if the topic is invalid

pub fn unsubscribe(
    &mut self,
    topic: &str,
    client: ServerClient
) -> Result<(), Error>

Errors

With return Err if the topic is invalid

pub fn get_subscribers(&self, topic: &str) -> HashSet<ServerClient>

Trait Implementations

impl Debug for ServerClientDB

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

Formats the value using the given formatter.

impl Default for ServerClientDB

fn default() -> Self

Returns the “default value” for a type.