RscStreamWriter.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::RscWriter;
 
// forwards
class RscStreamReader;
 
class ARP_EXPORT RscStreamWriter
{
    friend class RscStreamReader;
 
public: // construction
    RscStreamWriter(void);
    explicit RscStreamWriter(RscWriter& writer);
 
public: // setter/getter
    bool IsEmpty(void)const;
 
public: // Write operations (only allowed if RemotingWriter is set)
    void    Write(const byte* buffer, size_t bufferSize);
    void    SerializeFrom(Stream& stream);
    void    SerializeFrom(RscStreamReader& streamReader);
    void    Flush(void);
 
private: // methods
    void    BeginWrite(void);   // this operation is private now and invoked implicit
    void    EndWrite(void);     // this operation is private now and invoked implicit
    void    CheckNotEmpty(void);
 
private: // fields
    RscWriter*  pWriter = nullptr;
    bool        hasBegunWrite = false;
 
private: // static fields
    static constexpr int32  maxPacketSize = std::numeric_limits<int32>::max();
    static constexpr size_t copyBufferSize = 4096;
    static constexpr int32  endTag = -1;
};
 
} // end of namespace Arp::Base::Rsc::Commons