EventStreamBuf.h

 
#pragma once
 
#include <aws/core/Core_EXPORTS.h>
#include <ios>
#include <aws/core/utils/event/EventStreamDecoder.h>
#include <aws/core/utils/memory/stl/AWSStringStream.h>
 
namespace Aws
{
    namespace Utils
    {
        namespace Event
        {
            extern AWS_CORE_API const size_t DEFAULT_BUF_SIZE;
 
            class AWS_CORE_API EventStreamBuf : public std::streambuf
            {
            public:
                EventStreamBuf(EventStreamDecoder& decoder, size_t bufferLength = DEFAULT_BUF_SIZE);
                virtual ~EventStreamBuf();
 
            protected:
                std::streampos seekoff(std::streamoff off, std::ios_base::seekdir dir, std::ios_base::openmode which = std::ios_base::in | std::ios_base::out) override;
                std::streampos seekpos(std::streampos pos, std::ios_base::openmode which = std::ios_base::in | std::ios_base::out) override;
 
                int underflow() override;
                int overflow(int ch) override;
                int sync() override;
 
            private:
                void writeToDecoder();
 
                ByteBuffer m_byteBuffer;
                size_t m_bufferLength;
                Aws::StringStream m_err;
                EventStreamDecoder& m_decoder;
            };
        }
    }
}