Check if all active dimensions have been consumed in this cycle.
- Returns
- true if all active dimensions have been processed
Implements MayaFlux::Kakshya::SignalSourceContainer.
Definition at line 721 of file SoundStreamContainer.cpp.
722{
724
725 return std::ranges::all_of(
m_active_readers, [
this](
const auto& dim_reader_pair) {
726 const auto& [dim, expected_count] = dim_reader_pair;
727
729 [dim](const auto& reader_dims_pair) {
730 return reader_dims_pair.second.contains(dim);
731 });
732
733 return actual_count >= expected_count;
734 });
735}
std::unordered_map< uint32_t, int > m_active_readers
std::mutex m_reader_mutex
std::unordered_map< uint32_t, std::unordered_set< uint32_t > > m_reader_consumed_dimensions
void lock() override
Acquire a lock for thread-safe access.
References lock(), m_active_readers, m_reader_consumed_dimensions, and m_reader_mutex.