Output.h

Go to the documentation of this file.

 
/*
 * Output.h
 *
 *  Created on: Jun 23, 2016
 *      Author: mschefer
 */
 
#ifndef _SEFRAMEWORK_PIPELINE_OUTPUT_H_
#define _SEFRAMEWORK_PIPELINE_OUTPUT_H_
 
#include "SEFramework/Pipeline/PipelineStage.h"
#include "SEFramework/Source/SourceGroupInterface.h"
#include "SEFramework/Source/SourceInterface.h"
 
namespace SourceXtractor {
 
class Output : public PipelineReceiver<SourceGroupInterface> {
 
public:
  virtual ~Output() = default;
 
  void receiveSource(std::unique_ptr<SourceGroupInterface> source_group) override {
    for (auto& source : *source_group) {
      outputSource(source);
    }
  }
 
  void receiveProcessSignal(const ProcessSourcesEvent&) override {
    // pass
  }
 
  virtual void outputSource(const SourceInterface& source) = 0;
 
  virtual size_t flush() = 0;
 
  virtual void nextPart() = 0;
};
 
}
 
#endif /* _SEFRAMEWORK_PIPELINE_OUTPUT_H_ */