processing_function()

void MayaFlux::Buffers::StreamWriteProcessor::processing_function ( std::shared_ptr< Buffer >  buffer )

overridevirtual

Write buffer audio data to the appropriate container channel.

Extracts audio samples and streams them to the DynamicSoundStream channel corresponding to the AudioBuffer's channel ID.

Parameters

buffer

AudioBuffer containing data to write

Implements MayaFlux::Buffers::BufferProcessor.

Definition at line 8 of file StreamWriteProcessor.cpp.

{
    auto audio_buffer = std::dynamic_pointer_cast<AudioBuffer>(buffer);
    if (!audio_buffer || !m_container)
        return;
 
    std::span<const double> data_span = audio_buffer->get_data();
 
    if (data_span.empty())
        return;
 
    uint32_t channel_id = audio_buffer->get_channel_id();
 
    if (channel_id >= m_container->get_num_channels()) {
        std::cerr << "Warning: AudioBuffer channel " << channel_id
                  << " exceeds container channels (" << m_container->get_num_channels()
                  << "). Skipping write." << '\n';
        return;
    }
 
    uint64_t frames_written = m_container->write_frames(data_span, m_write_position, channel_id);
 
    if (frames_written > 0) {
        m_write_position += frames_written;
 
        if (m_container->is_circular() && m_write_position >= m_container->get_circular_capacity()) {
            m_write_position = 0;
        }
    }
}

References m_container, and m_write_position.