Aws::Eventstreamrpc::ClientConnection Class Reference

#include <EventStreamClient.h>

Public Member Functions
	ClientConnection (Crt::Allocator *allocator, aws_client_bootstrap *bootstrap) noexcept
	~ClientConnection () noexcept
std::future< RpcError >	Connect (const ConnectionConfig &connectionOptions, ConnectionLifecycleHandler *connectionLifecycleHandler) noexcept
std::shared_ptr< ClientContinuationImpl >	NewStream () noexcept
void	Close () noexcept
bool	IsOpen () const noexcept

Detailed Description

Class representing a connection to an RPC server.

Constructor & Destructor Documentation

ClientConnection()

Aws::Eventstreamrpc::ClientConnection::ClientConnection ( Crt::Allocator *  allocator, aws_client_bootstrap *  bootstrap  )

noexcept

~ClientConnection()

Aws::Eventstreamrpc::ClientConnection::~ClientConnection ( )

noexcept

Member Function Documentation

Close()

void Aws::Eventstreamrpc::ClientConnection::Close ( )

noexcept

Close the connection.

Connect()

std::future< RpcError > Aws::Eventstreamrpc::ClientConnection::Connect ( const ConnectionConfig &  connectionOptions, ConnectionLifecycleHandler *  connectionLifecycleHandler  )

noexcept

Initiates a new outgoing event-stream-rpc connection.

Parameters

connectionOptions	Connection options.
connectionLifecycleHandler	Handler to process connection lifecycle events.

Returns

Future that will be resolved when connection either succeeds or fails.

IsOpen()

bool Aws::Eventstreamrpc::ClientConnection::IsOpen ( ) const

noexcept

Check if the connection is open.

Returns

True if the connection is open, false otherwise.

NewStream()

std::shared_ptr< ClientContinuationImpl > Aws::Eventstreamrpc::ClientConnection::NewStream ( )

noexcept

Create a new stream (continuation).

Returns

A newly created continuation.

---

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

• eventstream_rpc/include/aws/eventstreamrpc/EventStreamClient.h
• eventstream_rpc/source/EventStreamClient.cpp