libpalliate v0.0.1
Palliate core library
|
#include <consumer.h>
Public Member Functions | |
~consumer () override=default | |
consumer (std::string const &_name, transport::Client &_handle) | |
bool | loop () override |
virtual void | handle (transport::reader_t message)=0 |
![]() | |
runnable (std::string const &_name) | |
virtual | ~runnable () |
virtual void | operator() (std::stop_token token={}) |
void | run () |
void | run (callback_f _callback) |
void | stop () |
auto | operator<=> (runnable const &other) const |
Protected Attributes | |
transport::Client & | client_handle |
![]() | |
std::jthread | thread |
std::unique_ptr< callback_t > | callback |
Additional Inherited Members | |
![]() | |
using | callback_f = std::function< void()> |
using | callback_t = std::stop_callback< callback_f > |
![]() | |
virtual bool | setup () |
virtual bool | loop ()=0 |
|
overridedefault |
|
inline |
|
pure virtual |
|
overridevirtual |
Implements runnable.
|
protected |