Sorter.h

Go to the documentation of this file.

/*
 * Sorter.h
 *
 *  Created on: Sep 10, 2018
 *      Author: Alejandro Alvarez Ayllon
 */
 
#ifndef _SEMAIN_SORTER_H_
#define _SEMAIN_SORTER_H_
 
#include "SEFramework/Pipeline/PipelineStage.h"
#include "SEFramework/Source/SourceGroupInterface.h"
#include <map>
 
namespace SourceXtractor {
 
class Sorter: public PipelineReceiver<SourceGroupInterface>, public PipelineEmitter<SourceGroupInterface> {
public:
 
  Sorter();
  virtual ~Sorter() = default;
 
  void receiveSource(std::unique_ptr<SourceGroupInterface> source) override;
  void receiveProcessSignal(const ProcessSourcesEvent& event) override;
 
private:
  std::map<int, std::unique_ptr<SourceGroupInterface>> m_output_buffer;
  int m_output_next;
};
 
} // end SourceXtractor
 
#endif // _SEMAIN_SORTER_H_