#include <Sorter.h>

Inheritance diagram for SourceXtractor::Sorter:

[legend]

Collaboration diagram for SourceXtractor::Sorter:

[legend]

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< T >
virtual	~Observable ()=default
	Destructor.

virtual void	addObserver (std::shared_ptr< Observer< T > > observer)
	Adds an Observer that will be notified when notify Observers is called.

virtual void	removeObserver (std::shared_ptr< Observer< T > > 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< T >
void	notifyObservers (const T &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.

◆ ~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 SourceXtractor::extractSourceId(), 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