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_ */