AWS IoT Device SDK C++ v2 1.14.0
AWS IoT Device SDK C++ v2
Public Member Functions | Protected Member Functions | List of all members
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 PublishToTopicOperationContext &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, StreamResponseHandler *streamHandler, const OperationModelContext &operationModelContext, Crt::Allocator *allocator) noexcept
 
 ~ClientOperation () noexcept
 
 ClientOperation (const ClientOperation &clientOperation) noexcept=delete
 
 ClientOperation (ClientOperation &&clientOperation) noexcept
 
std::future< RpcErrorClose (OnMessageFlushCallback onMessageFlushCallback=nullptr) noexcept
 
std::future< TaggedResultGetOperationResult () noexcept
 

Protected Member Functions

Aws::Crt::String GetModelName () const noexcept override
 
- Protected Member Functions inherited from Aws::Eventstreamrpc::ClientOperation
std::future< RpcErrorActivate (const AbstractShapeBase *shape, OnMessageFlushCallback onMessageFlushCallback) noexcept
 
std::future< RpcErrorSendStreamEvent (AbstractShapeBase *shape, OnMessageFlushCallback onMessageFlushCallback) noexcept
 

Additional Inherited Members

- Protected Attributes inherited from Aws::Eventstreamrpc::ClientOperation
const OperationModelContextm_operationModelContext
 

Constructor & Destructor Documentation

◆ PublishToTopicOperation()

Aws::Greengrass::PublishToTopicOperation::PublishToTopicOperation ( ClientConnection connection,
const PublishToTopicOperationContext 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.

◆ GetModelName()

Aws::Crt::String Aws::Greengrass::PublishToTopicOperation::GetModelName ( ) const
overrideprotectedvirtualnoexcept

◆ 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: