EventStreamClient.cpp File Reference

#include <aws/eventstreamrpc/EventStreamClient.h>
#include <aws/crt/Api.h>
#include <aws/crt/auth/Credentials.h>
#include <algorithm>
#include <cstdint>
#include <cstring>

Classes
class	Aws::Eventstreamrpc::OnMessageFlushCallbackContainer
class	Aws::Eventstreamrpc::OnMessageFlushCallbackContainerWrapper
class	Aws::Eventstreamrpc::ConnectionCallbackContext
class	Aws::Eventstreamrpc::ClientConnectionImpl
struct	Aws::Eventstreamrpc::AwsEventstreamConnectionImplClearSharedTask
struct	Aws::Eventstreamrpc::MessageDeserialization
struct	Aws::Eventstreamrpc::MessageResult
struct	Aws::Eventstreamrpc::ContinuationSharedState
class	Aws::Eventstreamrpc::ClientContinuationImpl
struct	Aws::Eventstreamrpc::AwsEventstreamContinuationReleaseTask

Namespaces
	Aws
	Aws::Eventstreamrpc

Enumerations
enum	Aws::Eventstreamrpc::ConnectionCallbackActionType { Aws::Eventstreamrpc::ConnectionCallbackActionType::None, Aws::Eventstreamrpc::ConnectionCallbackActionType::CompleteConnectPromise, Aws::Eventstreamrpc::ConnectionCallbackActionType::DisconnectionCallback }
enum	Aws::Eventstreamrpc::EventStreamMessageRoutingType { Aws::Eventstreamrpc::EventStreamMessageRoutingType::Response, Aws::Eventstreamrpc::EventStreamMessageRoutingType::Stream, Aws::Eventstreamrpc::EventStreamMessageRoutingType::Error }
enum	Aws::Eventstreamrpc::ContinuationStateType {   Aws::Eventstreamrpc::ContinuationStateType::None, Aws::Eventstreamrpc::ContinuationStateType::PendingActivate, Aws::Eventstreamrpc::ContinuationStateType::Activated, Aws::Eventstreamrpc::ContinuationStateType::PendingClose,   Aws::Eventstreamrpc::ContinuationStateType::Closed }

Functions
static void	Aws::Eventstreamrpc::s_protocolMessageCallback (int errorCode, void *userData) noexcept
static void	Aws::Eventstreamrpc::s_fillNativeHeadersArray (const Crt::List< EventStreamHeader > &headers, struct aws_array_list *headersArray, Crt::Allocator *m_allocator=Crt::g_allocator)
static void	Aws::Eventstreamrpc::s_zeroSharedReference (struct aws_task *task, void *arg, enum aws_task_status status)
static const EventStreamHeader *	Aws::Eventstreamrpc::s_GetHeaderByName (const Crt::List< EventStreamHeader > &headers, const Crt::String &name) noexcept
static void	Aws::Eventstreamrpc::s_releaseContinuation (struct aws_task *task, void *arg, enum aws_task_status status)

Variables
constexpr auto	EVENTSTREAM_VERSION_HEADER = ":version"
constexpr auto	EVENTSTREAM_VERSION_STRING = "0.1.0"
constexpr auto	CONTENT_TYPE_HEADER = ":content-type"
constexpr auto	CONTENT_TYPE_APPLICATION_JSON = "application/json"
constexpr auto	SERVICE_MODEL_TYPE_HEADER = "service-model-type"

Variable Documentation

CONTENT_TYPE_APPLICATION_JSON

constexpr auto CONTENT_TYPE_APPLICATION_JSON = "application/json"

constexpr

CONTENT_TYPE_HEADER

constexpr auto CONTENT_TYPE_HEADER = ":content-type"

constexpr

EVENTSTREAM_VERSION_HEADER

constexpr auto EVENTSTREAM_VERSION_HEADER = ":version"

constexpr

Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. SPDX-License-Identifier: Apache-2.0.

EVENTSTREAM_VERSION_STRING

constexpr auto EVENTSTREAM_VERSION_STRING = "0.1.0"

constexpr

SERVICE_MODEL_TYPE_HEADER

constexpr auto SERVICE_MODEL_TYPE_HEADER = "service-model-type"

constexpr