7 #include "Arp/System/Rsc/Services/Rsc.h" 8 #include "Arp/System/Rsc/Services/RemotingReader.hpp" 9 #include "Arp/System/Rsc/Services/RemotingWriter.hpp" 10 #include "Arp/System/Commons/Io/Stream.hpp" 12 namespace Arp {
namespace System {
namespace Rsc {
namespace Services
71 size_t Read(
byte* pBuffer,
size_t bufferSize);
94 void Write(
const byte* pBuffer,
size_t bufferCount);
107 RemotingWriter* pWriter =
nullptr;
108 RemotingReader* pReader =
nullptr;
109 bool initialized =
false;
114 static constexpr
int MaxPacketSize = std::numeric_limits<int>::max();
115 static constexpr
size_t BufferSize = 4096;
132 this->pWriter = value;
137 this->pReader = value;
RscStream(void)=default
Constructs an instance of RscStream
void BeginWrite(void)
Begins the write operation
void SetReader(RemotingReader *pValue)
Sets RemotingReader needed to read stream data
Definition: RscStream.hpp:135
void SetWriter(RemotingWriter *pValue)
Sets RemotingWriter needed to write stream data
Definition: RscStream.hpp:130
void Flush(void)
Ends the read writer operation and writes remaining internal buffered bytes
~RscStream(void)=default
Destructs this instance and frees all resources.
void DeserializeTo(Stream &stream)
Deserialize the stream data and copies it to the as agument passed stream
void Write(const byte *pBuffer, size_t bufferCount)
Writes data into stream
Provides a generic view of a sequence of bytes.
Definition: Stream.hpp:19
void Skip(void)
Skips the entire stream and disposes the read data
size_t Read(byte *pBuffer, size_t bufferSize)
Reads up to bufferSize byte into memory referenced by pBuffer
Enables Rsc services to marshal large data packets as stream.
Definition: RscStream.hpp:19
Root namespace for the PLCnext API
void SerializeFrom(Stream &stream)
Serialize the stream data from the as agument passed stream
System components used by the System, Device, Plc or Io domains.
void BeginRead(void)
Begins the read operation. Need pReader to be set.
unsigned char byte
The Arp character type.
Definition: PrimitiveTypes.hpp:23