ark::pipeline::PeriodicProducerStage

Defined in header “ark/pipeline/testing/producer_stage.hh”.

---

A stage that periodically publishes the given object from the specified list at a fixed rate. This can be used to help pump messages through your stage to test it.

Methods

• PeriodicProducerStage(std::vector< ObjectType > objects, std::chrono::nanoseconds rate, std::string channel_name, std::string name)
  Constructor. Initialize with a list of objects you wish to produce, and the rate you wish to produce them at.

• void initialize(pipeline::StageInterface & interface)
  Called from the executor when we are initialized.