rawdio 0.14.0

An Audio Engine, inspired by the Web Audio API
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118

use crate::{
    commands::{CancelChangeRequest, Command, Id, ParameterChangeRequest},
    engine::CommandQueue,
    prelude::*,
};

use super::DspParameters;

pub struct Dsp {
    id: Id,
    input_count: usize,
    output_count: usize,
    processor: Box<dyn DspProcessor + Send + Sync>,
    parameters: DspParameters,
}

/// The context that is passed to every [DspProcessor]
pub struct ProcessContext<'a> {
    /// The input buffer, containing the input channels into this node
    pub input_buffer: &'a dyn AudioBuffer,

    /// The output buffer, to be filled by this node
    pub output_buffer: &'a mut dyn AudioBuffer,

    /// The start time of the process block
    pub start_time: &'a Timestamp,

    /// The audio-rate parameters
    pub parameters: &'a DspParameters,
}

pub trait DspProcessor {
    fn process_audio(&mut self, context: &mut ProcessContext);
}

impl Dsp {
    pub fn new(
        id: Id,
        input_count: usize,
        output_count: usize,
        processor: Box<dyn DspProcessor + Send + Sync>,
        parameters: DspParameters,
    ) -> Self {
        Self {
            id,
            input_count,
            output_count,
            processor,
            parameters,
        }
    }

    pub fn input_count(&self) -> usize {
        self.input_count
    }

    pub fn output_count(&self) -> usize {
        self.output_count
    }

    pub fn add_to_audio_process(self, command_queue: &dyn CommandQueue) {
        command_queue.send(Command::AddDsp(Box::new(self)));
    }

    pub fn remove_from_audio_process(id: Id, command_queue: &dyn CommandQueue) {
        command_queue.send(Command::RemoveDsp(id));
    }

    pub fn get_id(&self) -> Id {
        self.id
    }

    pub fn process_audio(
        &mut self,
        input_buffer: &dyn AudioBuffer,
        output_buffer: &mut dyn AudioBuffer,
        start_time: &Timestamp,
    ) {
        assert_eq!(input_buffer.channel_count(), self.input_count);
        assert_eq!(output_buffer.channel_count(), self.output_count);

        for (_, parameter) in self.parameters.iter_mut() {
            parameter.process(
                start_time,
                output_buffer.frame_count(),
                output_buffer.sample_rate(),
            );
        }

        self.processor.process_audio(&mut ProcessContext {
            input_buffer,
            output_buffer,
            start_time,
            parameters: &self.parameters,
        });
    }

    pub fn request_parameter_change(&mut self, parameter_change: ParameterChangeRequest) {
        let parameter = self
            .parameters
            .get_parameter_mut(parameter_change.parameter_id);
        parameter.add_parameter_change(parameter_change.change);
    }

    pub fn cancel_parameter_changes(&mut self, change_request: CancelChangeRequest) {
        let parameter = self
            .parameters
            .get_parameter_mut(change_request.parameter_id);

        match change_request.end_time {
            Some(end_time) => parameter.cancel_scheduled_changes_ending_after(&end_time),
            None => parameter.cancel_scheduled_changes(),
        }
    }
}

#[cfg(test)]
mod tests {}