Partition.cpp

Go to the documentation of this file.

 
#include "SEFramework/Pipeline/Partition.h"
 
namespace SourceXtractor {
 
Partition::Partition(std::vector<std::shared_ptr<PartitionStep>> steps)
  : m_steps(std::move(steps)) {
}
 
void Partition::receiveSource(std::unique_ptr<SourceInterface> input_source) {
  // The input of the current step
  std::vector<std::unique_ptr<SourceInterface>> step_input_sources;
  step_input_sources.emplace_back(std::move(input_source));
 
  // Applies all the steps
  for (const auto& step : m_steps) {
    std::vector<std::unique_ptr<SourceInterface>> step_output_sources;
    // For each Source in pour input list
    for (auto& source : step_input_sources) {
      // applies the current step
      auto partition_output = step->partition(std::move(source));
      // then merges the result
      step_output_sources.insert(step_output_sources.end(), std::make_move_iterator(partition_output.begin()),
                                 std::make_move_iterator(partition_output.end()));
    }
 
    // the output of that step is then used as the input of the next
    step_input_sources = std::move(step_output_sources);
  }
 
  // Observers are then notified of the output of the last step
  for (auto& source : step_input_sources) {
    sendSource(std::move(source));
  }
}
void Partition::receiveProcessSignal(const ProcessSourcesEvent& event) {
  sendProcessSignal(event);
}
 
} // SEFramework namespace