Struct busrt::ipc::Client

pub struct Client { /* private fields */ }

Implementations

impl Client

pub async fn connect(config: &Config) -> Result<Self, Error>

pub async fn register_secondary(&self) -> Result<Self, Error>

pub fn get_timeout(&self) -> Duration

Trait Implementations

impl AsyncClient for Client

fn take_event_channel(&mut self) -> Option<EventChannel>

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

fn send<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    target: &'life1 str,
    payload: Cow<'async_trait>,
    qos: QoS
) -> Pin<Box<dyn Future<Output = Result<OpConfirm, Error>> + Send + 'async_trait>>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<OpConfirm, Error>> + Send + 'async_trait>>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<OpConfirm, Error>> + Send + 'async_trait>>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<OpConfirm, Error>> + Send + 'async_trait>>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<OpConfirm, Error>> + Send + 'async_trait>>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<OpConfirm, Error>> + Send + 'async_trait>>where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait,

fn subscribe_bulk<'life0, 'life1, 'life2, 'async_trait>(
    &'life0 mut self,
    topics: &'life1 [&'life2 str],
    qos: QoS
) -> Pin<Box<dyn Future<Output = Result<OpConfirm, Error>> + Send + 'async_trait>>where
    'life0: 'async_trait,
    'life1: 'async_trait,
    'life2: 'async_trait,
    Self: 'async_trait,

fn unsubscribe_bulk<'life0, 'life1, 'life2, 'async_trait>(
    &'life0 mut self,
    topics: &'life1 [&'life2 str],
    qos: QoS
) -> Pin<Box<dyn Future<Output = Result<OpConfirm, Error>> + Send + 'async_trait>>where
    'life0: 'async_trait,
    'life1: 'async_trait,
    'life2: 'async_trait,
    Self: 'async_trait,

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

fn is_connected(&self) -> bool

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

fn get_name(&self) -> &str

impl Drop for Client

fn drop(&mut self)

Executes the destructor for this type.