Trait Communicator 

pub trait Communicator:
    Capability
    + CommunicatorMethods
    + Send
    + Sync {
    // Required methods
    fn liveliness_subscribers(
        &self,
    ) -> Arc<RwLock<HashMap<String, Box<dyn LivelinessSubscriber>>>>;
    fn observers(&self) -> Arc<RwLock<HashMap<String, Box<dyn Observer>>>>;
    fn publishers(&self) -> Arc<RwLock<HashMap<String, Box<dyn Publisher>>>>;
    fn queriers(&self) -> Arc<RwLock<HashMap<String, Box<dyn Querier>>>>;
    fn responders(&self) -> Arc<RwLock<HashMap<String, Box<dyn Responder>>>>;
    fn uuid(&self) -> String;
    fn mode(&self) -> &String;
    fn default_session(&self) -> Arc<Session>;
    fn session(&self, id: &str) -> Option<Arc<Session>>;
    fn sessions(&self) -> Vec<Arc<Session>>;

    // Provided methods
    fn upgrade_capabilities(&self, new_state: &OperationState) -> Result<()> { ... }
    fn downgrade_capabilities(&self, new_state: &OperationState) -> Result<()> { ... }
}

the methodes to be implemented by any communicator

Required Methods

fn liveliness_subscribers( &self, ) -> Arc<RwLock<HashMap<String, Box<dyn LivelinessSubscriber>>>>

Get the liveliness subscribers

fn observers(&self) -> Arc<RwLock<HashMap<String, Box<dyn Observer>>>>

Get the observers

fn publishers(&self) -> Arc<RwLock<HashMap<String, Box<dyn Publisher>>>>

Get the publishers

fn queriers(&self) -> Arc<RwLock<HashMap<String, Box<dyn Querier>>>>

Get the queriers

fn responders(&self) -> Arc<RwLock<HashMap<String, Box<dyn Responder>>>>

Get the responders

fn uuid(&self) -> String

the uuid of the communicator

fn mode(&self) -> &String

the mode of the communicator

fn default_session(&self) -> Arc<Session>

get the default session

fn session(&self, id: &str) -> Option<Arc<Session>>

get the session with id

fn sessions(&self) -> Vec<Arc<Session>>

get all sessions

Provided Methods

fn upgrade_capabilities(&self, new_state: &OperationState) -> Result<()>

Method for upgrading OperationState all registered capabilities

The capabilities are upgraded in the order

• LivelinessSubscribers
• Responder: Observable, Queryable, Subscriber
• Publishers the
• Observers and the
• Queriers

Errors

Currently none

fn downgrade_capabilities(&self, new_state: &OperationState) -> Result<()>

Method for downgrading OperationState all registered capabilities

The capabilities are downgraded in reverse order of their start in Communicator::upgrade_capabilities

Errors

Currently none

Implementors

impl Communicator for MultiCommunicator

impl Communicator for SingleCommunicator