RscStreamReader.hpp

 
//
//  Copyright Phoenix Contact GmbH & Co. KG
//
#pragma once
#include "Arp/Base/Core/Arp.hpp"
#include "Arp/Base/Rsc/Commons/Rsc.hpp"
#include "Arp/Base/Commons/Io/Stream.hpp"
 
namespace Arp::Base::Rsc::Commons
{
 
// Type imports
using Arp::Base::Commons::Io::Stream;
using Arp::Base::Rsc::Commons::Services::RscReader;
 
// forwards
class RscStreamWriter;
 
class ARP_EXPORT RscStreamReader
{
    friend class RscStreamWriter;
 
public: // construction
    RscStreamReader(void);
    explicit RscStreamReader(RscReader& reader);
 
public: // setter/getter
    bool IsEmpty(void)const;
 
public: // Read/Deserialize operation
    size_t  Read(byte* pBuffer, size_t bufferSize);
    void    DeserializeTo(Stream& stream);
    void    DeserializeTo(RscStreamWriter& streamWriter);
    void    Skip(void);
 
private: // methods
    void    BeginRead(void); // this operation is private now and invoked implicit
    void    CheckNotEmpty(void);
 
private: // fields
    RscReader*  pReader = nullptr;
    bool        hasBegunRead = false;
    size_t      count = 0;
    size_t      remaining = 0;
 
private: // static fields
    static constexpr size_t defaultBufferSize = 4096;
 
};
 
} // end of namespace Arp::Base::Rsc::Commons