Struct MockClient

pub struct MockClient { /* private fields */ }

Mock implementation of an MQTT client.

Currently always succeeds on all operations.

Implementations

impl MockClient

pub fn new() -> Self

Return a new mocked MQTT client.

pub fn mock_controller(&self) -> MockClientController

Return a monitor that tracks the calls to this client (including any of its clones)

Trait Implementations

impl Clone for MockClient

fn clone(&self) -> MockClient

Returns a copy of the value.

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

Performs copy-assignment from source.

impl MqttAck for MockClient

fn ack<'life0, 'life1, 'async_trait>( &'life0 self, publish: &'life1 Publish, ) -> Pin<Box<dyn Future<Output = Result<CompletionToken, AckError>> + Send + 'async_trait>>

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

Acknowledge a received Publish.

impl MqttClient for MockClient

fn reauth<'life0, 'async_trait>( &'life0 self, auth_props: AuthProperties, ) -> Pin<Box<dyn Future<Output = Result<(), ReauthError>> + Send + 'async_trait>>

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

Reauthenticate with the MQTT broker

impl MqttDisconnect for MockClient

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

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

Disconnect from the MQTT broker.

impl MqttPubSub for MockClient

fn publish<'life0, 'async_trait>( &'life0 self, topic: impl 'async_trait + Into<String> + Send, qos: QoS, retain: bool, payload: impl 'async_trait + Into<Bytes> + Send, ) -> Pin<Box<dyn Future<Output = Result<CompletionToken, PublishError>> + Send + 'async_trait>>

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

MQTT Publish

fn publish_with_properties<'life0, 'async_trait>( &'life0 self, topic: impl 'async_trait + Into<String> + Send, qos: QoS, retain: bool, payload: impl 'async_trait + Into<Bytes> + Send, properties: PublishProperties, ) -> Pin<Box<dyn Future<Output = Result<CompletionToken, PublishError>> + Send + 'async_trait>>

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

MQTT Publish

fn subscribe<'life0, 'async_trait>( &'life0 self, topic: impl 'async_trait + Into<String> + Send, qos: QoS, ) -> Pin<Box<dyn Future<Output = Result<CompletionToken, SubscribeError>> + Send + 'async_trait>>

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

MQTT Subscribe

fn subscribe_with_properties<'life0, 'async_trait>( &'life0 self, topic: impl 'async_trait + Into<String> + Send, qos: QoS, properties: SubscribeProperties, ) -> Pin<Box<dyn Future<Output = Result<CompletionToken, SubscribeError>> + Send + 'async_trait>>

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

MQTT Subscribe

fn unsubscribe<'life0, 'async_trait>( &'life0 self, topic: impl 'async_trait + Into<String> + Send, ) -> Pin<Box<dyn Future<Output = Result<CompletionToken, UnsubscribeError>> + Send + 'async_trait>>

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

MQTT Unsubscribe

fn unsubscribe_with_properties<'life0, 'async_trait>( &'life0 self, topic: impl 'async_trait + Into<String> + Send, properties: UnsubscribeProperties, ) -> Pin<Box<dyn Future<Output = Result<CompletionToken, UnsubscribeError>> + Send + 'async_trait>>

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

MQTT Unsubscribe