A source of messages to be deserialized and processed. More...
#include <message.hh>
Public Member Functions | |
reader (const reader &)=delete | |
reader (reader_type &_reader) | |
std::optional< message > | get_next () |
int | append_raw_message_stream (container::ring_buffer< char > &buffer) |
Internal method which populates the reader object. More... | |
A source of messages to be deserialized and processed.
R | internal binary reader type |
|
delete |
aether::message::reader< R >::reader | ( | reader_type & | _reader | ) |
int aether::message::reader< R >::append_raw_message_stream | ( | container::ring_buffer< char > & | buffer | ) |
Internal method which populates the reader object.
std::optional<message> aether::message::reader< R >::get_next | ( | ) |