buffered_stream.h

 
#pragma once
 
#include "system/io/stream.h"
#include "system/reflection.h"
 
namespace System { namespace IO {
    class ASPOSECPP_SHARED_CLASS BufferedStream : public Stream
    {
        RTTI_INFO(System::IO::BufferedStream, ::System::BaseTypesInfo<System::IO::Stream>);
    public:
        ASPOSECPP_SHARED_API BufferedStream(const SharedPtr<Stream>& stream);
        ASPOSECPP_SHARED_API BufferedStream(const SharedPtr<Stream>& stream, int bufferSize);
        virtual ASPOSECPP_SHARED_API ~BufferedStream();
 
    public: //Stream impl.
        virtual ASPOSECPP_SHARED_API int ReadByte() override;
        virtual ASPOSECPP_SHARED_API void WriteByte(uint8_t value) override;
        virtual ASPOSECPP_SHARED_API int32_t Read(const ArrayPtr<uint8_t>& buffer, int32_t offset, int32_t count) override;
        virtual ASPOSECPP_SHARED_API int32_t Read(const System::Details::ArrayView<uint8_t>& buffer, int32_t offset, int32_t count) override;
        virtual ASPOSECPP_SHARED_API void Write(const ArrayPtr<uint8_t>& buffer, int32_t offset, int32_t count) override;
        virtual ASPOSECPP_SHARED_API void Write(const System::Details::ArrayView<uint8_t>& buffer, int32_t offset, int32_t count) override;
        virtual ASPOSECPP_SHARED_API int64_t Seek(int64_t offset, SeekOrigin origin) override;
        virtual ASPOSECPP_SHARED_API void SetLength(int64_t value) override;
        virtual ASPOSECPP_SHARED_API void Flush() override;
 
    public: //Stream impl.
        virtual ASPOSECPP_SHARED_API void set_Position(int64_t value) override;
        virtual ASPOSECPP_SHARED_API int64_t get_Position() const override;
        virtual ASPOSECPP_SHARED_API int64_t get_Length() const override;
        virtual ASPOSECPP_SHARED_API bool get_CanRead() const override;
        virtual ASPOSECPP_SHARED_API bool get_CanSeek() const override;
        virtual ASPOSECPP_SHARED_API bool get_CanWrite() const override;
 
    private:
 
        template<template<typename T> class ArrT> int32_t _Read(const ArrT<uint8_t> & buffer, int32_t offset, int32_t count);
        template<template<typename T> class ArrT> void _Write(const ArrT<uint8_t>& buffer, int32_t offset, int32_t count);
 
    private:
        SharedPtr<Stream> m_stream;
        ArrayPtr<uint8_t> m_buffer;
        int m_buffer_pos;
        int m_buffer_read_ahead;
        bool m_buffer_reading;
    };
 
}}