AWS IoT Device SDK C++ v2
1.39.0
AWS IoT Device SDK C++ v2
|
#include <EventStreamClient.h>
Public Member Functions | |
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< RpcError > | Close (OnMessageFlushCallback onMessageFlushCallback=nullptr) noexcept |
void | WithLaunchMode (std::launch mode) noexcept |
![]() | |
virtual | ~ClientContinuationHandler () noexcept=default |
Protected Member Functions | |
std::future< RpcError > | Activate (const AbstractShapeBase *shape, OnMessageFlushCallback &&onMessageFlushCallback, std::function< void(EventstreamResultVariantType &&)> &&onResultCallback) noexcept |
std::future< RpcError > | SendStreamMessage (const AbstractShapeBase *shape, OnMessageFlushCallback &&onMessageFlushCallback) noexcept |
virtual Crt::String | GetModelName () const noexcept |
Interface for an RPC operation.
|
noexcept |
|
overridenoexcept |
|
deletenoexcept |
|
deletenoexcept |
|
protectednoexcept |
Initiate a new client stream. Send the shape for the new stream.
shape | A parameter for RPC operation. |
onMessageFlushCallback | Callback to invoke when the shape is flushed to the underlying transport. |
onResultCallback | Callback to invoke with the untransformed activation result |
|
noexcept |
Close the stream on which operation is sent.
onMessageFlushCallback | Callback to invoke when the closing message is flushed to the underlying transport. |
|
protectedvirtualnoexcept |
Returns the canonical model name associated with this operation across any client language. Namespace included.
|
deletenoexcept |
|
deletenoexcept |
|
protectednoexcept |
Sends a message on the stream
shape | Modeled representation of the message to send |
onMessageFlushCallback | Optional callback to invoke when the message is written or fails to send |
|
noexcept |
Set the launch mode for executing operations. The mode is set to std::launch::deferred by default.
mode | The launch mode to use. |