BufferInputStreamAdapter.h

Go to the documentation of this file.

 
#pragma once
#include "Stream.h"
#include "catapult/exceptions.h"
#include <sstream>
 
namespace catapult { namespace io {
 
    template<typename TContainer>
    class BufferInputStreamAdapter : public InputStream {
    public:
        explicit BufferInputStreamAdapter(const TContainer& input)
                : m_input(input)
                , m_position(0)
        {}
 
    public:
        size_t position() const {
            return m_position;
        }
 
    public:
        bool eof() const override {
            RawBuffer input(m_input);
            return m_position == input.Size;
        }
 
        void read(const MutableRawBuffer& buffer) override {
            RawBuffer input(m_input);
            if (buffer.Size + m_position > input.Size) {
                std::ostringstream out;
                out
                        << "BufferInputStreamAdapter invalid read (buffer-size = " << buffer.Size
                        << ", position = " << m_position
                        << ", input-size = " << input.Size << ")";
                CATAPULT_THROW_FILE_IO_ERROR(out.str().c_str());
            }
 
            std::memcpy(buffer.pData, input.pData + m_position, buffer.Size);
            m_position += buffer.Size;
        }
 
    private:
        const TContainer& m_input;
        size_t m_position;
    };
}}