Struct GlobalState 

pub struct GlobalState { /* private fields */ }

Implementations

impl GlobalState

pub fn new() -> Self

pub async fn add_client( &self, client_identifier: &str, sender: Sender<Outgoing>, ) -> Result<AddClientReceipt, Error>

pub fn remove_client<'a>( &self, client_id: ClientId, subscribes: impl IntoIterator<Item = &'a TopicFilter>, )

pub fn subscribe( &self, filter: &TopicFilter, id: ClientId, qos: QualityOfService, )

pub fn unsubscribe(&self, filter: &TopicFilter, id: ClientId)

pub fn get_outgoing_sender( &self, client_id: &ClientId, ) -> Option<Sender<Outgoing>>

pub fn retain_table(&self) -> &RetainTable

pub fn route_table(&self) -> &RouteTable

Trait Implementations

impl Default for GlobalState

fn default() -> GlobalState

Returns the “default value” for a type.