process_filtered()

void MayaFlux::Kakshya::DataProcessingChain::process_filtered	(	std::shared_ptr< SignalSourceContainer >	container,
		std::function< bool(std::shared_ptr< DataProcessor >)>	filter
	)

Processes a container with processors that match a filter function.

Parameters

container	The signal container to process
filter	Function that determines which processors to apply

Enables dynamic, runtime filtering of processors based on arbitrary criteria, such as processor state, metadata, or external conditions.

Definition at line 56 of file DataProcessingChain.cpp.

{
    auto it = m_container_processors.find(container);
    if (it != m_container_processors.end()) {
        for (auto& processor : it->second) {
            if (filter(processor)) {
                processor->process(container);
            }
        }
    }
}

References m_container_processors.