SourceXtractor::Sorter Class Reference

#include <Sorter.h>

Inheritance diagram for SourceXtractor::Sorter:

Collaboration diagram for SourceXtractor::Sorter:

Public Member Functions
	Sorter ()
virtual	~Sorter ()=default
void	receiveSource (std::unique_ptr< SourceGroupInterface > source) override
void	receiveProcessSignal (const ProcessSourcesEvent &event) override
Public Member Functions inherited from SourceXtractor::PipelineReceiver< SourceGroupInterface >
virtual	~PipelineReceiver ()=default
Public Member Functions inherited from SourceXtractor::PipelineEmitter< SourceGroupInterface >
	~PipelineEmitter () override=default
void	setNextStage (std::shared_ptr< PipelineReceiver< SourceGroupInterface > > next)
Public Member Functions inherited from SourceXtractor::Observable< SourceGroupInterface >
virtual	~Observable ()=default
	Destructor.
virtual void	addObserver (std::shared_ptr< Observer< SourceGroupInterface > > observer)
	Adds an Observer that will be notified when notify Observers is called.
virtual void	removeObserver (std::shared_ptr< Observer< SourceGroupInterface > > observer)
	Removes a previously added Observer from the list of Observers to notify.

Private Attributes
std::map< int, std::unique_ptr< SourceGroupInterface > >	m_output_buffer
int	m_output_next

Additional Inherited Members
Protected Member Functions inherited from SourceXtractor::PipelineEmitter< SourceGroupInterface >
void	sendSource (std::unique_ptr< SourceGroupInterface > source) const
void	sendProcessSignal (const ProcessSourcesEvent &event) const
Protected Member Functions inherited from SourceXtractor::Observable< SourceGroupInterface >
void	notifyObservers (const SourceGroupInterface &message) const

Detailed Description

Definition at line 33 of file Sorter.h.

Constructor & Destructor Documentation

Sorter()

SourceXtractor::Sorter::Sorter

(

)

Definition at line 29 of file Sorter.cpp.

References m_output_next.

~Sorter()

virtual SourceXtractor::Sorter::~Sorter ( )

virtualdefault

Member Function Documentation

receiveProcessSignal()

void SourceXtractor::Sorter::receiveProcessSignal ( const ProcessSourcesEvent & event )

overridevirtual

Receive a signal to process sources when grouping

Parameters

event

Implements SourceXtractor::PipelineReceiver< SourceGroupInterface >.

Definition at line 47 of file Sorter.cpp.

References SourceXtractor::PipelineEmitter< SourceGroupInterface >::sendProcessSignal().

Here is the call graph for this function:

receiveSource()

void SourceXtractor::Sorter::receiveSource ( std::unique_ptr< SourceGroupInterface > source )

overridevirtual

Receive a source from the previous stage. The receiver owns the object.

Parameters

source

Implements SourceXtractor::PipelineReceiver< SourceGroupInterface >.

Definition at line 32 of file Sorter.cpp.

References std::vector< T >::begin(), std::vector< T >::end(), SourceXtractor::extractSourceId(), std::vector< T >::front(), m_output_buffer, m_output_next, std::move(), SourceXtractor::PipelineEmitter< SourceGroupInterface >::sendSource(), std::sort(), and std::transform().

Here is the call graph for this function:

Member Data Documentation

m_output_buffer

std::map<int, std::unique_ptr<SourceGroupInterface> > SourceXtractor::Sorter::m_output_buffer

private

Definition at line 43 of file Sorter.h.

Referenced by receiveSource().

m_output_next

int SourceXtractor::Sorter::m_output_next

private

Definition at line 44 of file Sorter.h.

Referenced by receiveSource(), and Sorter().

---

The documentation for this class was generated from the following files:

• SEMain/SEMain/Sorter.h
• SEMain/src/lib/Sorter.cpp