Class MoshiProcessor

web_demo/client/src/audio-processor.ts:20–238

}

class MoshiProcessor extends AudioWorkletProcessor {
  constructor() {
    super();
    console.log("Audio Queue Processor initialized", currentFrame, sampleRate);
    
    // ============ 缓冲区配置 ============
    const frameSize = asSamples(40);  // 每帧 80ms
    
    // 初始缓冲：收集多少数据后开始播放（越大越平滑，但延迟越高）
    // 建议 240-320ms (3-4帧)，可以容忍 2-3 个帧的网络抖动
    this.initialBufferSamples = 12 * frameSize;  // 240ms
    
    // 启动后的额外等待时间
    this.startupDelaySamples = asSamples(40);  // 40ms
    
    // Buffer underrun 后的最小恢复缓冲
    this.minRecoveryBuffer = asSamples(40);  // 80ms
    
    // 状态初始化
    this.initState();

    // 消息处理
    this.port.onmessage = (event) => {
      if (event.data.type === "reset") {
        console.log("[AudioProcessor] Reset state");
        this.initState();
        return;
      }
      
      // 将音频帧加入队列
      const frame = event.data.frame;
      this.audioQueue.push(frame);
      this.totalQueuedSamples += frame.length;
      
      // 检查是否可以开始播放
      if (!this.isPlaying && this.totalQueuedSamples >= this.initialBufferSamples) {
        this.startPlayback();
      }
      
      // 日志（前20个包）
      if (this.packetCount < 20) {
        console.log(
          this.timestamp(),
          `[Queue] Packet #${this.packetCount++}`,
          `queued: ${asMs(this.totalQueuedSamples)}ms`,
          `frame: ${asMs(frame.length)}ms`
        );
      }
      
      // 发送状态给主线程
      this.port.postMessage({
        totalAudioPlayed: this.totalAudioPlayed,
        actualAudioPlayed: this.actualAudioPlayed,
        delay: event.data.micDuration - this.playbackPosition,
        minDelay: this.minDelay,
        maxDelay: this.maxDelay,
        queueSize: this.totalQueuedSamples,
      });