63 lines
1.6 KiB
TypeScript
63 lines
1.6 KiB
TypeScript
declare global {
|
|
interface AudioWorkletProcessor {
|
|
readonly port: MessagePort;
|
|
process(
|
|
inputs: Float32Array[][],
|
|
outputs: Float32Array[][],
|
|
parameters: Map<string, Float32Array>
|
|
): void;
|
|
}
|
|
|
|
const AudioWorkletProcessor: {
|
|
prototype: AudioWorkletProcessor;
|
|
new (options?: AudioWorkletNodeOptions): AudioWorkletProcessor;
|
|
};
|
|
|
|
function registerProcessor(
|
|
name: string,
|
|
ctor: { new (): AudioWorkletProcessor }
|
|
): void;
|
|
}
|
|
|
|
export interface AppleAudioMessageEvent extends MessageEvent {
|
|
data: Float32Array;
|
|
}
|
|
|
|
export class AppleAudioProcessor extends AudioWorkletProcessor {
|
|
private samples: Float32Array[] = [];
|
|
|
|
constructor() {
|
|
super();
|
|
console.info('AppleAudioProcessor constructor');
|
|
this.port.onmessage = (ev: AppleAudioMessageEvent) => {
|
|
this.samples.push(ev.data);
|
|
if (this.samples.length > 256) {
|
|
this.samples.shift();
|
|
}
|
|
};
|
|
}
|
|
|
|
static get parameterDescriptors() {
|
|
return [];
|
|
}
|
|
|
|
process(
|
|
_inputList: Float32Array[][],
|
|
outputList: Float32Array[][],
|
|
_parameters: Map<string, Float32Array>
|
|
) {
|
|
const sample = this.samples.shift();
|
|
const output = outputList[0];
|
|
if (sample) {
|
|
for (let idx = 0; idx < sample.length; idx++) {
|
|
output[0][idx] = sample[idx];
|
|
}
|
|
}
|
|
|
|
// Keep alive indefinitely.
|
|
return true;
|
|
}
|
|
}
|
|
|
|
registerProcessor('audio_worker', AppleAudioProcessor);
|