aether::message::reader< R > Class Template Reference

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< messageget_next ()
 
int append_raw_message_stream (container::ring_buffer< char > &buffer)
 Internal method which populates the reader object. More...
 

Detailed Description

template<typename R>
class aether::message::reader< R >

A source of messages to be deserialized and processed.

Template Parameters
Rinternal binary reader type

Constructor & Destructor Documentation

template<typename R >
aether::message::reader< R >::reader ( const reader< R > &  )
delete
template<typename R >
aether::message::reader< R >::reader ( reader_type &  _reader)

Member Function Documentation

template<typename R >
int aether::message::reader< R >::append_raw_message_stream ( container::ring_buffer< char > &  buffer)

Internal method which populates the reader object.

template<typename R >
std::optional<message> aether::message::reader< R >::get_next ( )
Returns
The next message available to read. Once all messages are processed returns an empty option.