MqttRequestResponseClient.cpp File Reference

#include <aws/iot/MqttRequestResponseClient.h>
#include <aws/crt/mqtt/Mqtt5Client.h>
#include <aws/crt/mqtt/MqttConnection.h>
#include <aws/common/ref_count.h>
#include <aws/common/rw_lock.h>

Classes
class	Aws::Iot::RequestResponse::StreamReadLock
class	Aws::Iot::RequestResponse::StreamWriteLock
class	Aws::Iot::RequestResponse::StreamingOperationImpl
struct	Aws::Iot::RequestResponse::StreamingOperationImplHandle
class	Aws::Iot::RequestResponse::StreamingOperation
struct	Aws::Iot::RequestResponse::IncompleteRequest
class	Aws::Iot::RequestResponse::MqttRequestResponseClientImpl
class	Aws::Iot::RequestResponse::MqttRequestResponseClient

Namespaces
namespace	Aws
namespace	Aws::Iot
namespace	Aws::Iot::RequestResponse

Functions
static void	Aws::Iot::RequestResponse::s_completeRequestWithError (struct IncompleteRequest *incompleteRequest, int errorCode)
static void	Aws::Iot::RequestResponse::s_completeRequestWithSuccess (struct IncompleteRequest *incompleteRequest, const struct aws_byte_cursor *response_topic, const struct aws_byte_cursor *payload)
static void	Aws::Iot::RequestResponse::s_onRequestComplete (const struct aws_byte_cursor *response_topic, const struct aws_byte_cursor *payload, int error_code, void *user_data)
static void	Aws::Iot::RequestResponse::s_onClientTermination (void *user_data)
AWS_CRT_CPP_API std::shared_ptr< IMqttRequestResponseClient >	Aws::Iot::RequestResponse::NewClientFrom5 (const Aws::Crt::Mqtt5::Mqtt5Client &protocolClient, const RequestResponseClientOptions &options, Aws::Crt::Allocator *allocator=Aws::Crt::ApiAllocator())
AWS_CRT_CPP_API std::shared_ptr< IMqttRequestResponseClient >	Aws::Iot::RequestResponse::NewClientFrom311 (const Aws::Crt::Mqtt::MqttConnection &protocolClient, const RequestResponseClientOptions &options, Aws::Crt::Allocator *allocator=Aws::Crt::ApiAllocator())