AWS IoT Device SDK C++ v2 1.44.1
AWS IoT Device SDK C++ v2
Loading...
Searching...
No Matches
Aws::Greengrass::PublishToTopicOperation Class Reference

#include <GreengrassCoreIpcModel.h>

Inheritance diagram for Aws::Greengrass::PublishToTopicOperation:
Aws::Eventstreamrpc::ClientOperation Aws::Eventstreamrpc::ClientContinuationHandler

Public Member Functions

 PublishToTopicOperation (ClientConnection &connection, const std::shared_ptr< OperationModelContext > &operationContext, Aws::Crt::Allocator *allocator=Aws::Crt::g_allocator) noexcept
std::future< RpcErrorActivate (const PublishToTopicRequest &request, OnMessageFlushCallback onMessageFlushCallback=nullptr) noexcept
std::future< PublishToTopicResultGetResult () noexcept
Public Member Functions inherited from Aws::Eventstreamrpc::ClientOperation
 ClientOperation (ClientConnection &connection, std::shared_ptr< StreamResponseHandler > streamHandler, const std::shared_ptr< OperationModelContext > &operationModelContext, Crt::Allocator *allocator) noexcept
 ~ClientOperation () noexcept override
 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< RpcErrorClose (OnMessageFlushCallback onMessageFlushCallback=nullptr) noexcept
void WithLaunchMode (std::launch mode) noexcept
Public Member Functions inherited from Aws::Eventstreamrpc::ClientContinuationHandler
virtual ~ClientContinuationHandler () noexcept=default

Additional Inherited Members

Protected Member Functions inherited from Aws::Eventstreamrpc::ClientOperation
std::future< RpcErrorActivate (const AbstractShapeBase *shape, OnMessageFlushCallback &&onMessageFlushCallback, std::function< void(EventstreamResultVariantType &&)> &&onResultCallback) noexcept
std::future< RpcErrorSendStreamMessage (const AbstractShapeBase *shape, OnMessageFlushCallback &&onMessageFlushCallback) noexcept
virtual Crt::String GetModelName () const noexcept

Constructor & Destructor Documentation

◆ PublishToTopicOperation()

Aws::Greengrass::PublishToTopicOperation::PublishToTopicOperation ( ClientConnection & connection,
const std::shared_ptr< OperationModelContext > & operationContext,
Aws::Crt::Allocator * allocator = Aws::Crt::g_allocator )
noexcept

Member Function Documentation

◆ Activate()

std::future< RpcError > Aws::Greengrass::PublishToTopicOperation::Activate ( const PublishToTopicRequest & request,
OnMessageFlushCallback onMessageFlushCallback = nullptr )
noexcept

Used to activate a stream for the PublishToTopicOperation

Parameters
requestThe request used for the PublishToTopicOperation
onMessageFlushCallbackAn optional callback that is invoked when the request is flushed.
Returns
An RpcError that can be used to check whether the stream was activated.

◆ GetResult()

std::future< PublishToTopicResult > Aws::Greengrass::PublishToTopicOperation::GetResult ( )
noexcept

Retrieve the result from activating the stream.


The documentation for this class was generated from the following files: