Struct SingleCommunicator 

pub struct SingleCommunicator { /* private fields */ }

a multi session communicator

Implementations

impl SingleCommunicator

pub fn new(config: &Config) -> Result<Self>

Constructor

Errors

Trait Implementations

impl Capability for SingleCommunicator

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

Checks whether state of capability component is appropriate for the given OperationState. If not, implementation has to adjusts components state to needs.

impl Communicator for SingleCommunicator

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 queries

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

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

Method for upgrading OperationState all registered capabilities

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

Method for downgrading OperationState all registered capabilities

impl CommunicatorMethods for SingleCommunicator

fn put(&self, selector: &str, message: Message) -> Result<()>

Send a put message Message to the given selector.

fn delete(&self, selector: &str) -> Result<()>

Send a delete message to the given selector.

fn get( &self, selector: &str, message: Option<Message>, callback: Option<&mut dyn FnMut(QueryableMsg) -> Result<()>>, ) -> Result<()>

Send a query with an optional specification Message to the given selector.

fn observe(&self, selector: &str, message: Option<Message>) -> Result<()>

Request an observation for Message from the given selector

fn watch(&self, _selector: &str, _message: Message) -> Result<()>

Request a stream configured by Message from the given selector

impl Debug for SingleCommunicator

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

Formats the value using the given formatter.