Parent class for arbitrary producers of packages. More...
#include <pipeline.h>

Public Member Functions | |
| virtual void | setupProducer (const size_t max_num_tries=0, const std::chrono::milliseconds reconnection_time=std::chrono::seconds(10)) |
| Set-up functionality of the producers. More... | |
| virtual void | startProducer () |
| virtual void | stopProducer () |
| Stops the producer. More... | |
| virtual void | teardownProducer () |
| Fully tears down the producer - by default no difference to stopping it. More... | |
| virtual bool | tryGet (std::vector< std::unique_ptr< T >> &products)=0 |
| Reads packages from some source and produces corresponding objects. More... | |
| virtual | ~IProducer ()=default |
Parent class for arbitrary producers of packages.
| T | Type of the produced products |
Definition at line 206 of file pipeline.h.
|
virtualdefault |
|
inlinevirtual |
Set-up functionality of the producers.
| max_num_tries | Maximum number of connection attempts before counting the connection as failed. Unlimited number of attempts when set to 0. |
| reconnection_time | time in between connection attempts to the server |
Reimplemented in urcl::comm::URProducer< T >.
Definition at line 218 of file pipeline.h.
|
inlinevirtual |
Reimplemented in urcl::comm::URProducer< T >.
Definition at line 236 of file pipeline.h.
|
inlinevirtual |
Stops the producer.
Reimplemented in urcl::comm::URProducer< T >.
Definition at line 232 of file pipeline.h.
|
inlinevirtual |
Fully tears down the producer - by default no difference to stopping it.
Reimplemented in urcl::comm::URProducer< T >.
Definition at line 225 of file pipeline.h.
|
pure virtual |
Reads packages from some source and produces corresponding objects.
| products | Vector of unique pointers to be filled with produced packages. |
Implemented in urcl::comm::URProducer< T >.