process_typed()

template<typename ProcessorType >

void MayaFlux::Kakshya::DataProcessingChain::process_typed ( const std::shared_ptr< SignalSourceContainer > &  container )

inline

Processes a container with only processors of a specific derived type.

Template Parameters

ProcessorType

Concrete DataProcessor subtype to dispatch to.

Parameters

container

The signal container to process.

Definition at line 84 of file DataProcessingChain.hpp.

    {
        bool expected = false;
        if (!m_is_processing.compare_exchange_strong(expected, true,
                std::memory_order_acquire, std::memory_order_relaxed)) {
            return;
        }
 
        auto it = m_container_processors.find(container);
        if (it != m_container_processors.end()) {
            for (auto& processor : it->second) {
                if (auto typed = std::dynamic_pointer_cast<ProcessorType>(processor)) {
                    typed->process(container);
                }
            }
        }
 
        m_is_processing.store(false, std::memory_order_release);
        drain_pending_removals();
    }