Struct ClientNoQueue 

pub struct ClientNoQueue<'a, C, D, F, const P: usize>
where
    C: Connection,
    D: Delay,
    F: EventHandler<P>,
{ /* private fields */ }

Implementations

impl<'a, C, D, F, const P: usize> ClientNoQueue<'a, C, D, F, P>

where C: Connection, D: Delay, F: EventHandler<P>,

pub fn new( connection: C, buf: &'a mut [u8], delay: D, timeout_millis: u32, event_handler: F, ) -> Self

Trait Implementations

impl<'a, C, D, F, const P: usize> Client<'a> for ClientNoQueue<'a, C, D, F, P>

where C: Connection, D: Delay, F: EventHandler<P>,

async fn connect_with_will<const W: usize>( &mut self, settings: &ConnectionSettings<'_>, will: Option<Will<'_, W>>, ) -> Result<(), ClientError>

Connect to server with a will

async fn connect( &mut self, settings: &ConnectionSettings<'_>, ) -> Result<(), ClientError>

Connect to server

async fn disconnect(&mut self) -> Result<(), ClientError>

Disconnect from server

async fn publish_with_properties<'b, const PP: usize>( &'b mut self, topic_name: &'b str, payload: &'b [u8], qos: QualityOfService, retain: bool, properties: Vec<PublishProperty<'b>, PP>, ) -> Result<(), ClientError>

Publish a message with given payload to a given topic, with properties

async fn subscribe<'b>( &'b mut self, topic_name: &'b str, maximum_qos: QualityOfService, ) -> Result<(), ClientError>

Subscribe to a topic

async fn unsubscribe<'b>( &'b mut self, topic_name: &'b str, ) -> Result<(), ClientError>

Unsubscribe from a topic

async fn send_ping(&mut self) -> Result<(), ClientError>

Send a ping message to broker

async fn poll(&mut self, wait: bool) -> Result<bool, ClientError>

Poll for and handle at most one event This updates the state of the client, and calls the event_handler if a message is received If wait is true, this will wait until an event is received, or the comms are disconnected. Otherwise an event will only be waited for if at least one byte of data is already available, indicating a packet should be available soon. On success, returns true if an event was handled, false if none was received Errors indicate an invalid packet was received, message_target errored, the received packet was unexpected based on our state, or the comms are disconnected.

async fn perform<'b, const PP: usize>( &'b mut self, action: ClientAction<'b, PP>, ) -> Result<(), ClientError>

Perform an action (this replicates the functionality of Client::subscribe, Client::unsubscribe and Client::publish) but using an enum to represent the action.

async fn publish<'b>( &'b mut self, topic_name: &'b str, payload: &'b [u8], qos: QualityOfService, retain: bool, ) -> Result<(), ClientError>

Publish a message with given payload to a given topic, with no properties