Trait eva_sdk::prelude::AsyncClient

source · [−]
pub trait AsyncClient: Send + Sync {

Show 14 methods    fn take_event_channel(&mut self) -> Option<Receiver<Arc<FrameData>>>;

    fn send<'life0, 'life1, 'async_trait>(
        &'life0 mut self, 
        target: &'life1 str, 
        payload: Cow<'async_trait>, 
        qos: QoS
    ) -> Pin<Box<dyn Future<Output = Result<Option<Receiver<Result<(), Error>>>, Error>> + Send + 'async_trait, Global>>
    where
        'life0: 'async_trait,
        'life1: 'async_trait,
        Self: 'async_trait;

    fn zc_send<'life0, 'life1, 'async_trait>(
        &'life0 mut self, 
        target: &'life1 str, 
        header: Cow<'async_trait>, 
        payload: Cow<'async_trait>, 
        qos: QoS
    ) -> Pin<Box<dyn Future<Output = Result<Option<Receiver<Result<(), Error>>>, Error>> + Send + 'async_trait, Global>>
    where
        'life0: 'async_trait,
        'life1: 'async_trait,
        Self: 'async_trait;

    fn send_broadcast<'life0, 'life1, 'async_trait>(
        &'life0 mut self, 
        target: &'life1 str, 
        payload: Cow<'async_trait>, 
        qos: QoS
    ) -> Pin<Box<dyn Future<Output = Result<Option<Receiver<Result<(), Error>>>, Error>> + Send + 'async_trait, Global>>
    where
        'life0: 'async_trait,
        'life1: 'async_trait,
        Self: 'async_trait;

    fn publish<'life0, 'life1, 'async_trait>(
        &'life0 mut self, 
        target: &'life1 str, 
        payload: Cow<'async_trait>, 
        qos: QoS
    ) -> Pin<Box<dyn Future<Output = Result<Option<Receiver<Result<(), Error>>>, Error>> + Send + 'async_trait, Global>>
    where
        'life0: 'async_trait,
        'life1: 'async_trait,
        Self: 'async_trait;

    fn subscribe<'life0, 'life1, 'async_trait>(
        &'life0 mut self, 
        topic: &'life1 str, 
        qos: QoS
    ) -> Pin<Box<dyn Future<Output = Result<Option<Receiver<Result<(), Error>>>, Error>> + Send + 'async_trait, Global>>
    where
        'life0: 'async_trait,
        'life1: 'async_trait,
        Self: 'async_trait;

    fn unsubscribe<'life0, 'life1, 'async_trait>(
        &'life0 mut self, 
        topic: &'life1 str, 
        qos: QoS
    ) -> Pin<Box<dyn Future<Output = Result<Option<Receiver<Result<(), Error>>>, Error>> + Send + 'async_trait, Global>>
    where
        'life0: 'async_trait,
        'life1: 'async_trait,
        Self: 'async_trait;

    fn subscribe_bulk<'life0, 'life1, 'async_trait>(
        &'life0 mut self, 
        topics: Vec<&'life1 str, Global>, 
        qos: QoS
    ) -> Pin<Box<dyn Future<Output = Result<Option<Receiver<Result<(), Error>>>, Error>> + Send + 'async_trait, Global>>
    where
        'life0: 'async_trait,
        'life1: 'async_trait,
        Self: 'async_trait;

    fn unsubscribe_bulk<'life0, 'life1, 'async_trait>(
        &'life0 mut self, 
        topics: Vec<&'life1 str, Global>, 
        qos: QoS
    ) -> Pin<Box<dyn Future<Output = Result<Option<Receiver<Result<(), Error>>>, Error>> + Send + 'async_trait, Global>>
    where
        'life0: 'async_trait,
        'life1: 'async_trait,
        Self: 'async_trait;

    fn ping<'life0, 'async_trait>(
        &'life0 mut self
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait, Global>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;

    fn is_connected(&self) -> bool;

    fn get_connected_beacon(&self) -> Option<Arc<AtomicBool>>;

    fn get_timeout(&self) -> Option<Duration>;

    fn get_name(&self) -> &str;

}

Required methods

Implementations on Foreign Types

Panics

Will panic if the mutex is poisoned

Panics

Will panic if the mutex is poisoned

Panics

Will panic if the mutex is poisoned

Panics

Will panic if the mutex is poisoned

Implementors