use std::fmt::Debug;
use crate::buffer::{ChannelConfig, ChannelConfigOptions, ChannelCountMode, ChannelInterpretation};
use crate::context::{AsBaseAudioContext, AudioContextRegistration};
use crate::process::{AudioParamValues, AudioProcessor};
use crate::SampleRate;
use super::AudioNode;
pub struct ChannelSplitterOptions {
pub number_of_outputs: u32,
pub channel_config: ChannelConfigOptions,
}
impl Default for ChannelSplitterOptions {
fn default() -> Self {
Self {
number_of_outputs: 6,
channel_config: ChannelConfigOptions {
count: 6, mode: ChannelCountMode::Explicit,
interpretation: ChannelInterpretation::Discrete,
},
}
}
}
pub struct ChannelSplitterNode {
registration: AudioContextRegistration,
channel_config: ChannelConfig,
}
impl AudioNode for ChannelSplitterNode {
fn registration(&self) -> &AudioContextRegistration {
&self.registration
}
fn channel_config_raw(&self) -> &ChannelConfig {
&self.channel_config
}
fn set_channel_count(&self, _v: usize) {
panic!("Cannot edit channel count of ChannelSplitterNode")
}
fn set_channel_count_mode(&self, _v: ChannelCountMode) {
panic!("Cannot edit channel count mode of ChannelSplitterNode")
}
fn set_channel_interpretation(&self, _v: ChannelInterpretation) {
panic!("Cannot edit channel interpretation of ChannelSplitterNode")
}
fn number_of_inputs(&self) -> u32 {
1
}
fn number_of_outputs(&self) -> u32 {
self.channel_count() as _
}
}
impl ChannelSplitterNode {
pub fn new<C: AsBaseAudioContext>(context: &C, mut options: ChannelSplitterOptions) -> Self {
context.base().register(move |registration| {
options.channel_config.count = options.number_of_outputs as _;
let node = ChannelSplitterNode {
registration,
channel_config: options.channel_config.into(),
};
let render = ChannelSplitterRenderer {
number_of_outputs: node.channel_count() as _,
};
(node, Box::new(render))
})
}
}
#[derive(Debug)]
struct ChannelSplitterRenderer {
pub number_of_outputs: usize,
}
impl AudioProcessor for ChannelSplitterRenderer {
fn process(
&mut self,
inputs: &[crate::alloc::AudioBuffer],
outputs: &mut [crate::alloc::AudioBuffer],
_params: AudioParamValues,
_timestamp: f64,
_sample_rate: SampleRate,
) {
let input = &inputs[0];
assert_eq!(self.number_of_outputs, outputs.len());
for (i, output) in outputs.iter_mut().enumerate() {
output.force_mono();
if i < input.number_of_channels() {
*output.channel_data_mut(0) = input.channel_data(i).clone();
} else {
output.make_silent();
}
}
}
fn tail_time(&self) -> bool {
false
}
}