Struct ChannelClient 

pub struct ChannelClient { /* private fields */ }

A Client implementation that uses channels for message passing.

Examples

See ChannelEventLoop

Trait Implementations

impl Client for ChannelClient

fn disconnect<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), ()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Disconnects the client.

fn publish_state_message<'life0, 'async_trait>( &'life0 self, topic: StateTopic, payload: StatePayload, ) -> Pin<Box<dyn Future<Output = Result<(), ()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Publishes a state message to the specified state topic.

fn try_publish_state_message<'life0, 'async_trait>( &'life0 self, topic: StateTopic, payload: StatePayload, ) -> Pin<Box<dyn Future<Output = Result<(), ()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Attempts to publish a state message to the specified state topic.

fn publish_node_message<'life0, 'async_trait>( &'life0 self, topic: NodeTopic, payload: Payload, ) -> Pin<Box<dyn Future<Output = Result<(), ()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Publishes a message to a node-specific topic.

fn try_publish_node_message<'life0, 'async_trait>( &'life0 self, topic: NodeTopic, payload: Payload, ) -> Pin<Box<dyn Future<Output = Result<(), ()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Attempts to publish a message to a node-specific topic.

fn publish_device_message<'life0, 'async_trait>( &'life0 self, topic: DeviceTopic, payload: Payload, ) -> Pin<Box<dyn Future<Output = Result<(), ()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Publishes a message to a device-specific topic.

fn try_publish_device_message<'life0, 'async_trait>( &'life0 self, topic: DeviceTopic, payload: Payload, ) -> Pin<Box<dyn Future<Output = Result<(), ()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Attempts to publish a message to a device-specific topic.

fn subscribe_many<'life0, 'async_trait>( &'life0 self, topics: Vec<TopicFilter>, ) -> Pin<Box<dyn Future<Output = Result<(), ()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Subscribes to multiple topics in a single operation.

fn subscribe<'life0, 'async_trait>( &'life0 self, topic: TopicFilter, ) -> Pin<Box<dyn Future<Output = Result<(), ()>> + Send + 'async_trait>>

where Self: Sync + 'async_trait, 'life0: 'async_trait,

Subscribes to a single topic.

impl Clone for ChannelClient

fn clone(&self) -> ChannelClient

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.