let buf = null;
registerProcessor(
"AudioSender",
class AudioSender extends AudioWorkletProcessor {
constructor() {
super();
this.port.onmessage = async (event) => {
let opts = event.data;
buf = ringbuffer(
opts.pcmSab,
opts.pcmBufOpts.size,
opts.pcmBufOpts.max,
Float32Array,
);
};
}
process(inputs, outputs) {
if (buf) {
let samples = inputs[0][0];
buf.push(samples);
}
return true;
}
}
);