Struct AWSIoTAsyncClient

pub struct AWSIoTAsyncClient { /* private fields */ }

Implementations

impl AWSIoTAsyncClient

pub async fn new( settings: AWSIoTSettings, ) -> Result<(AWSIoTAsyncClient, (EventLoop, Sender<Incoming>)), AWSIoTError>

Create new AWSIoTAsyncClient. Input argument should be the AWSIoTSettings. Returns a tuple where the first element is the AWSIoTAsyncClient, and the second element is a new tuple with the eventloop and incoming event sender. This tuple should be sent as an argument to the async_event_loop_listener.

pub async fn subscribe<S: Into<String>>( &self, topic: S, qos: QoS, ) -> Result<(), ClientError>

Subscribe to a topic.

pub async fn publish<S, V>( &self, topic: S, qos: QoS, payload: V, ) -> Result<(), ClientError>

where S: Into<String>, V: Into<Vec<u8>>,

Publish to topic.

pub async fn get_receiver(&self) -> Receiver<Incoming>

Get a receiver of the incoming messages. Send this to any function that wants to read the incoming messages from IoT Core.

pub async fn get_client(self) -> AsyncClient

If you want to use the Rumqttc AsyncClient and EventLoop manually, this method can be used to get the AsyncClient.