Deblending.cpp

Go to the documentation of this file.

 
#include "SEFramework/Pipeline/Deblending.h"
 
namespace SourceXtractor {
 
Deblending::Deblending(std::vector<std::shared_ptr<DeblendStep>> deblend_steps)
  : m_deblend_steps(std::move(deblend_steps)) {
}
 
void Deblending::receiveSource(std::unique_ptr<SourceGroupInterface> group) {
 
  // Applies every DeblendStep to the SourceGroup
  for (auto& step : m_deblend_steps) {
    step->deblend(*group);
  }
 
  // If the SourceGroup still contains sources, we notify the observers
  if (group->begin() != group->end()) {
    sendSource(std::move(group));
  }
}
 
std::set<PropertyId> Deblending::requiredProperties() const {
  std::set<PropertyId> properties;
  for (auto& step : m_deblend_steps) {
    auto step_props = step->requiredProperties();
    std::copy(step_props.begin(), step_props.end(), std::inserter(properties, properties.end()));
  }
  return properties;
}
 
void Deblending::receiveProcessSignal(const ProcessSourcesEvent& event) {
  sendProcessSignal(event);
}
 
} // SEFramework namespace