ark::pipeline::MirrorStage

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

---

A stage that “mirrors” inputs any input it receives, it publishes on its own subscriber.

Methods

• MirrorStage(std::string input_channel, std::string output_channel, std::string name)
  Constructor. Redirects from the input channel to the output channel.

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