CommunicatorImplementationMethods

Trait CommunicatorImplementationMethods 

Source
pub trait CommunicatorImplementationMethods {
    // Provided methods
    fn put(&self, _selector: &str, _message: Message) -> Result<()> { ... }
    fn delete(&self, _selector: &str) -> Result<()> { ... }
    fn get(
        &self,
        _selector: &str,
        _message: Option<Message>,
        _callback: Option<&mut dyn FnMut(QueryableMsg) -> Result<()>>,
    ) -> Result<()> { ... }
    fn observe(&self, _selector: &str, _message: Option<Message>) -> Result<()> { ... }
    fn watch(&self, _selector: &str, _message: Message) -> Result<()> { ... }
}
Expand description

the communication methods to be implemented by any Communicator implementation

Provided Methods§

Source

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

Send a put message Message to the given selector.

§Errors
  • NotImplemented: there is no implementation within this communicator
Source

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

Send a delete message to the given selector.

§Errors
  • NotImplemented: there is no implementation within this communicator
Source

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.

§Errors
  • NotImplemented: there is no implementation within this communicator
Source

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

Request an observation for Message from the given selector

§Errors
  • NotImplemented: there is no implementation within this communicator
Source

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

Request a stream configured by Message from the given selector

§Errors
  • NotImplemented: there is no implementation within this communicator

Implementors§