Aws::Eventstreamrpc::ClientContinuationImpl Class Reference

Inheritance diagram for Aws::Eventstreamrpc::ClientContinuationImpl:

Public Member Functions
	ClientContinuationImpl (Aws::Crt::Allocator *allocator, struct aws_client_bootstrap *bootstrap, struct aws_event_stream_rpc_client_connection *connection) noexcept
virtual	~ClientContinuationImpl ()
void	ShutDown () noexcept
std::future< RpcError >	Activate (const Crt::String &operation, const Crt::List< EventStreamHeader > &headers, const Crt::Optional< Crt::ByteBuf > &payload, MessageType messageType, uint32_t messageFlags, std::function< void(EventstreamResultVariantType &&)> &&onResultCallback, OnMessageFlushCallback &&onMessageFlushCallback) noexcept
std::future< RpcError >	SendStreamMessage (const Crt::List< EventStreamHeader > &headers, const Crt::Optional< Crt::ByteBuf > &payload, MessageType messageType, uint32_t messageFlags, OnMessageFlushCallback &&onMessageFlushCallback)
std::future< RpcError >	Close (OnMessageFlushCallback &&onMessageFlushCallback=nullptr) noexcept
Crt::String	GetModelName () const noexcept
void	Initialize (const std::shared_ptr< OperationModelContext > &operationModelContext, std::shared_ptr< StreamResponseHandler > streamHandler) noexcept

Constructor & Destructor Documentation

ClientContinuationImpl()

Aws::Eventstreamrpc::ClientContinuationImpl::ClientContinuationImpl ( Aws::Crt::Allocator * allocator, struct aws_client_bootstrap * bootstrap, struct aws_event_stream_rpc_client_connection * connection )

noexcept

~ClientContinuationImpl()

Aws::Eventstreamrpc::ClientContinuationImpl::~ClientContinuationImpl ( )

virtual

Member Function Documentation

Activate()

std::future< RpcError > Aws::Eventstreamrpc::ClientContinuationImpl::Activate ( const Crt::String & operation, const Crt::List< EventStreamHeader > & headers, const Crt::Optional< Crt::ByteBuf > & payload, MessageType messageType, uint32_t messageFlags, std::function< void(EventstreamResultVariantType &&)> && onResultCallback, OnMessageFlushCallback && onMessageFlushCallback )

noexcept

Close()

std::future< RpcError > Aws::Eventstreamrpc::ClientContinuationImpl::Close ( OnMessageFlushCallback && onMessageFlushCallback = nullptr )

noexcept

GetModelName()

Crt::String Aws::Eventstreamrpc::ClientContinuationImpl::GetModelName ( ) const

noexcept

Initialize()

void Aws::Eventstreamrpc::ClientContinuationImpl::Initialize ( const std::shared_ptr< OperationModelContext > & operationModelContext, std::shared_ptr< StreamResponseHandler > streamHandler )

inlinenoexcept

SendStreamMessage()

std::future< RpcError > Aws::Eventstreamrpc::ClientContinuationImpl::SendStreamMessage	(	const Crt::List< EventStreamHeader > &	headers,
		const Crt::Optional< Crt::ByteBuf > &	payload,
		MessageType	messageType,
		uint32_t	messageFlags,
		OnMessageFlushCallback &&	onMessageFlushCallback )

ShutDown()

void Aws::Eventstreamrpc::ClientContinuationImpl::ShutDown ( )

noexcept

---

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

• eventstream_rpc/source/EventStreamClient.cpp