Deblending.h

Go to the documentation of this file.

 
#ifndef _SEFRAMEWORK_PIPELINE_DEBLENDING_H
#define _SEFRAMEWORK_PIPELINE_DEBLENDING_H
 
#include "SEFramework/Pipeline/PipelineStage.h"
#include "SEFramework/Source/SourceGroupInterface.h"
#include "SEFramework/Task/TaskProvider.h"
 
namespace SourceXtractor {

class DeblendStep {
public:

  virtual ~DeblendStep() = default;

  virtual void deblend(SourceGroupInterface& group) const = 0;

  virtual std::set<PropertyId> requiredProperties() const { return {};}
};

class Deblending : public PipelineReceiver<SourceGroupInterface>, public PipelineEmitter<SourceGroupInterface> {
 
public:

  virtual ~Deblending() = default;

  explicit Deblending(std::vector<std::shared_ptr<DeblendStep>> deblend_steps);

  void receiveSource(std::unique_ptr<SourceGroupInterface> group) override;
 
  void receiveProcessSignal(const ProcessSourcesEvent& event) override;

  std::set<PropertyId> requiredProperties() const;
 
private:
  std::vector<std::shared_ptr<DeblendStep>> m_deblend_steps;
}; /* End of Deblending class */
 
} /* namespace SourceXtractor */
 
 
#endif