MayaFlux 0.5.0
Digital-First Multimedia Processing Framework
Loading...
Searching...
No Matches

◆ drain_pending_removals()

void MayaFlux::Kakshya::DataProcessingChain::drain_pending_removals ( )
private

Flushes all removals deferred during the most recent process iteration.

Definition at line 68 of file DataProcessingChain.cpp.

69{
70 for (auto& [processor, container] : m_pending_removal) {
71 remove_processor_direct(processor, container);
72 }
73 m_pending_removal.clear();
74}
void remove_processor_direct(const std::shared_ptr< DataProcessor > &processor, const std::shared_ptr< SignalSourceContainer > &container)
Performs immediate removal of a processor from the chain.
std::vector< std::pair< std::shared_ptr< DataProcessor >, std::shared_ptr< SignalSourceContainer > > > m_pending_removal
Removals deferred because they arrived during active iteration.

References m_pending_removal, and remove_processor_direct().

Referenced by process(), process_filtered(), and process_tagged().

+ Here is the call graph for this function:
+ Here is the caller graph for this function: