AssocGrouping.h

Go to the documentation of this file.

 
#ifndef _SEIMPLEMENTATION_GROUPING_ASSOCGROUPING_H_
#define _SEIMPLEMENTATION_GROUPING_ASSOCGROUPING_H_
 
#include <map>
 
#include "SEFramework/Pipeline/SourceGrouping.h"
 
namespace SourceXtractor {
 
class AssocGrouping : public SourceGroupingInterface {
public:
 
  AssocGrouping(std::shared_ptr<SourceGroupFactory> group_factory, unsigned int hard_limit);
  virtual ~AssocGrouping() = default;
 
  std::set<PropertyId> requiredProperties() const override;

  void receiveSource(std::unique_ptr<SourceInterface> source) override;

  void receiveProcessSignal(const ProcessSourcesEvent& event) override;
 
private:
  std::shared_ptr<SourceGroupFactory> m_group_factory;
  std::map<unsigned int, std::unique_ptr<SourceGroupInterface>> m_source_groups;
  unsigned int m_hard_limit;
 
};
 
}
 
#endif /* _SEIMPLEMENTATION_GROUPING_ASSOCGROUPING_H_ */