SourceGrouping takes Source, groups them together according to its GroupingCriteria and stores them. When a ProcessSourcesEvent is received the sources that need to be processed are output together with the sources they are grouped with as a SourceGroup. More...

#include <SourceGrouping.h>

Inheritance diagram for SourceXtractor::SourceGrouping:

[legend]

Collaboration diagram for SourceXtractor::SourceGrouping:

[legend]

Public Member Functions
virtual	~SourceGrouping ()=default
	Destructor.

	SourceGrouping (std::shared_ptr< GroupingCriteria > grouping_criteria, std::shared_ptr< SourceGroupFactory > group_factory, unsigned int hard_limit)

std::set< PropertyId >	requiredProperties () const
	Returns the set of required properties to compute the grouping.

void	receiveSource (std::unique_ptr< SourceInterface > source) override
	Handles a new Source.

void	receiveProcessSignal (const ProcessSourcesEvent &event) override
	Handles a ProcessSourcesEvent to trigger the processing of some of the Sources stored in SourceGrouping.

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.

Public Member Functions inherited from SourceXtractor::PipelineReceiver< SourceInterface >
virtual	~PipelineReceiver ()=default

Private Attributes
std::shared_ptr< GroupingCriteria >	m_grouping_criteria

std::shared_ptr< SourceGroupFactory >	m_group_factory

std::list< std::unique_ptr< SourceGroupInterface > >	m_source_groups

unsigned int	m_hard_limit

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

SourceGrouping takes Source, groups them together according to its GroupingCriteria and stores them. When a ProcessSourcesEvent is received the sources that need to be processed are output together with the sources they are grouped with as a SourceGroup.

Definition at line 91 of file SourceGrouping.h.

Constructor & Destructor Documentation

◆ ~SourceGrouping()

virtual SourceXtractor::SourceGrouping::~SourceGrouping ( )

virtualdefault

Destructor.

◆ SourceGrouping()

SourceXtractor::SourceGrouping::SourceGrouping	(	std::shared_ptr< GroupingCriteria >	grouping_criteria,
		std::shared_ptr< SourceGroupFactory >	group_factory,
		unsigned int	hard_limit )