EventStreamDecoder.h

 
#pragma once
 
#include <aws/core/Core_EXPORTS.h>
#include <aws/core/utils/Array.h>
#include <aws/core/utils/event/EventStreamHandler.h>
#include <aws/event-stream/event_stream.h>
 
namespace Aws
{
    namespace Utils
    {
        namespace Event
        {
            class AWS_CORE_API EventStreamDecoder
            {
            public:
                EventStreamDecoder(EventStreamHandler* handler);
                ~EventStreamDecoder();
 
                inline explicit operator bool() const { return *m_eventStreamHandler; }
 
                void Pump(const ByteBuffer& data);
                void Pump(const ByteBuffer& data, size_t length);
 
                void Reset();
 
                void ResetEventStreamHandler(EventStreamHandler* handler);
 
            protected:
                static void onPayloadSegment(
                    aws_event_stream_streaming_decoder* decoder,
                    aws_byte_buf* payload,
                    int8_t isFinalSegment,
                    void* context);
 
                static void onPreludeReceived(
                    aws_event_stream_streaming_decoder* decoder,
                    aws_event_stream_message_prelude* prelude,
                    void* context);
 
                static void onHeaderReceived(
                    aws_event_stream_streaming_decoder* decoder,
                    aws_event_stream_message_prelude* prelude,
                    aws_event_stream_header_value_pair* header,
                    void* context);
 
                static void onError(
                    aws_event_stream_streaming_decoder* decoder,
                    aws_event_stream_message_prelude* prelude,
                    int errorCode,
                    const char* message,
                    void* context);
 
                aws_event_stream_streaming_decoder m_decoder;
                EventStreamHandler* m_eventStreamHandler;
            };
        }
    }
}