Struct aws_iot_device_sdk_rust::AWSIoTAsyncClient

pub struct AWSIoTAsyncClient { /* fields omitted */ }

Implementations

impl AWSIoTAsyncClient

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

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_eventloop_handle(&self) -> RumqttcSender<Request>

Get an eventloop handle that can be used to interract with the eventloop. Not needed if you are only using client.publish and client.subscribe.

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.