AWS IoT Device SDK C++ v2
1.34.0
AWS IoT Device SDK C++ v2
|
#include <GreengrassCoreIpcModel.h>
Public Member Functions | |
PublishToTopicOperation (ClientConnection &connection, const PublishToTopicOperationContext &operationContext, Aws::Crt::Allocator *allocator=Aws::Crt::g_allocator) noexcept | |
std::future< RpcError > | Activate (const PublishToTopicRequest &request, OnMessageFlushCallback onMessageFlushCallback=nullptr) noexcept |
std::future< PublishToTopicResult > | GetResult () noexcept |
Public Member Functions inherited from Aws::Eventstreamrpc::ClientOperation | |
ClientOperation (ClientConnection &connection, std::shared_ptr< StreamResponseHandler > streamHandler, const OperationModelContext &operationModelContext, Crt::Allocator *allocator) noexcept | |
~ClientOperation () noexcept | |
ClientOperation (const ClientOperation &clientOperation) noexcept=delete | |
ClientOperation (ClientOperation &&clientOperation) noexcept=delete | |
bool | operator= (const ClientOperation &clientOperation) noexcept=delete |
bool | operator= (ClientOperation &&clientOperation) noexcept=delete |
std::future< RpcError > | Close (OnMessageFlushCallback onMessageFlushCallback=nullptr) noexcept |
std::future< TaggedResult > | GetOperationResult () noexcept |
void | WithLaunchMode (std::launch mode) noexcept |
Public Member Functions inherited from Aws::Eventstreamrpc::ClientContinuationHandler | |
virtual | ~ClientContinuationHandler () noexcept=default |
Protected Member Functions | |
Aws::Crt::String | GetModelName () const noexcept override |
Protected Member Functions inherited from Aws::Eventstreamrpc::ClientOperation | |
std::future< RpcError > | Activate (const AbstractShapeBase *shape, OnMessageFlushCallback onMessageFlushCallback) noexcept |
Additional Inherited Members | |
Protected Attributes inherited from Aws::Eventstreamrpc::ClientOperation | |
const OperationModelContext & | m_operationModelContext |
std::launch | m_asyncLaunchMode |
|
noexcept |
|
noexcept |
Used to activate a stream for the PublishToTopicOperation
request | The request used for the PublishToTopicOperation |
onMessageFlushCallback | An optional callback that is invoked when the request is flushed. |
RpcError
that can be used to check whether the stream was activated.
|
overrideprotectedvirtualnoexcept |
Returns the canonical model name associated with this operation across any client language. Namespace included.
Implements Aws::Eventstreamrpc::ClientOperation.
|
noexcept |
Retrieve the result from activating the stream.