JANA/Topology/JEventTapArrow.h

0001 // Copyright 2024, Jefferson Science Associates, LLC.
0002 // Subject to the terms in the LICENSE file found in the top-level directory.
0003
0004 #pragma once
0005
0006 #include <JANA/Topology/JArrow.h>
0007
0008 class JEventProcessor;
0009 class JEvent;
0010
0011
0012 class JEventTapArrow : public JArrow {
0013 public:
0014     enum PortIndex {EVENT_IN=0, EVENT_OUT=1};
0015
0016 private:
0017     std::vector<JEventProcessor*> m_procs;
0018
0019 public:
0020     JEventTapArrow(std::string name);
0021
0022     void add_processor(JEventProcessor* proc);
0023
0024     void fire(JEvent* event, OutputData& outputs, size_t& output_count, JArrow::FireResult& status) final;
0025     void initialize() final;
0026     void finalize() final;
0027 };
0028