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