Method process

web_demo/client/src/audio-processor.ts:157–237

(inputs, outputs, parameters)

  }

  process(inputs, outputs, parameters) {
    const output = outputs[0][0];
    const outputLength = output.length;
    
    // 更新延迟统计
    const currentDelay = this.totalQueuedSamples / sampleRate;
    if (this.isPlaying && this.totalQueuedSamples > 0) {
      this.maxDelay = Math.max(this.maxDelay, currentDelay);
      this.minDelay = Math.min(this.minDelay, currentDelay);
    }
    
    // 还未开始播放 - 输出静音
    if (!this.isPlaying) {
      // output 默认已经是 0
      return true;
    }
    
    // 启动倒计时 - 额外等待一小段时间让缓冲更充足
    if (this.startupCountdown > 0) {
      this.startupCountdown -= outputLength;
      return true;
    }
    
    // 从队列获取音频
    const { buffer, actualSamples } = this.getAudioFromQueue(outputLength);
    
    // 复制到输出
    if (actualSamples > 0) {
      output.set(buffer.subarray(0, actualSamples), 0);
      
      // 首次输出 - 淡入效果
      if (this.isFirstOutput) {
        this.isFirstOutput = false;
        console.log(
          this.timestamp(),
          `[Playback] First output, queue: ${asMs(this.totalQueuedSamples)}ms`
        );
        // 淡入
        for (let i = 0; i < Math.min(actualSamples, 256); i++) {
          output[i] *= i / 256;
        }
      }
    }
    
    // Buffer underrun - 队列空了
    if (actualSamples < outputLength) {
      this.underrunCount++;
      console.log(
        this.timestamp(),
        `[Underrun #${this.underrunCount}] Missing ${outputLength - actualSamples} samples,`,
        `queue: ${asMs(this.totalQueuedSamples)}ms`
      );
      
      // 淡出已播放的部分，避免爆音
      if (actualSamples > 0) {
        const fadeLength = Math.min(actualSamples, 128);
        for (let i = 0; i < fadeLength; i++) {
          output[actualSamples - 1 - i] *= i / fadeLength;